Flink HDFS Sink 如何保证 exactly-once 语义

本文将从源码层面来分析在Flink中是如何保证sink数据到HDFS的exactly-once语义的。html Flink中sink数据到HDFS是由BucketingSink来完成。BucketingSink产生的HDFS文件路径格式以下，java /{base/path}/{bucket/path}/{part_prefix}-{parallel_task_index}-{count}{par

>>阅读原文<<