Flink學習筆記（十）：容錯機制與狀態一致性

1.Flink容錯機制 上圖的含義：假如輸入是1、2、3這樣的連續數字，按順序輸入，sum_even子任務計算偶數的和，sum_odd子任務計算奇數的和。如果在數字5被處理完成後做了一次checkpoint，那麼input的偏移量5、偶數之和6、奇數之和9共同組成一個快照一起checkpoint。 如果這個時間input已經消費到7，偶數求和已經得出結果12，基數在求和時出現故障，那麼這個時間點能

>>阅读原文<<