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

>>阅读原文<<