Flink容錯機制

Flink故障恢復機制的核心，就是應用狀態的一致性檢查點（Checkpoint） 有狀態流應用的一致性檢查點，就是在某個時間點的一份拷貝（一份快照），在這個時間點是所有任務都恰好處理完一個相同的輸入數據的時間 此應用有一個source task，消費一個遞增數的流，如1，2，3等等。流中的數據被分區到一個基數流，一個偶數流。在一個sum operator中，有兩個task，分別用於累加基數與偶數。

>>阅读原文<<