Flink-容錯機制 | 一致性檢查點 | 檢查點到恢復狀態過程 | Flink檢查點算法(Chandy-Lamport) | 算法操作解析 | 保存點簡介

一致性檢查點（Checkpoints） Flink 故障恢復機制的核心，就是應用狀態的一致性檢查點 有狀態流應用的一致檢查點，其實就是所有任務的狀態，在某個時間點的一份拷貝（一份快照）；這個時間點，應該是所有任務都恰好處理完一個相同的輸入數據的時候(如5這個數據雖然進了奇數流但是偶數流也應該做快照，因爲屬於同一個相同數據，只是沒有被他處理) 在JobManager中也有個Chechpoint的指針

>>阅读原文<<