Flink容错机制

Flink故障恢复机制的核心，就是应用状态的一致性检查点（Checkpoint） 有状态流应用的一致性检查点，就是在某个时间点的一份拷贝（一份快照），在这个时间点是所有任务都恰好处理完一个相同的输入数据的时间 此应用有一个source task，消费一个递增数的流，如1，2，3等等。流中的数据被分区到一个基数流，一个偶数流。在一个sum operator中，有两个task，分别用于累加基数与偶数。

>>阅读原文<<