Flink学习笔记（十）：容错机制与状态一致性

1.Flink容错机制 上图的含义：假如输入是1、2、3这样的连续数字，按顺序输入，sum_even子任务计算偶数的和，sum_odd子任务计算奇数的和。如果在数字5被处理完成后做了一次checkpoint，那么input的偏移量5、偶数之和6、奇数之和9共同组成一个快照一起checkpoint。 如果这个时间input已经消费到7，偶数求和已经得出结果12，基数在求和时出现故障，那么这个时间点能

>>阅读原文<<