詳解Flink檢查點算法原理--基於Chandy-Lamport算法的分佈式快照

Flink的恢復機制的核心就是應用狀態的一致性檢查點，有狀態流的一致性檢查點，其實就是所有狀態在某個時間點的一份快照拷貝，而這個時間點應該是所有任務都恰好處理完同一個輸入數據。 ** Flink使用的檢查點算法是分佈式快照算法（基於Chandy-Lamport算法的分佈式快照） ** 檢查點的兩種實現： （1）檢查點算法的簡單實現–暫停應用，保存狀態到檢查點，在重新恢復應用 （2）Flink基於檢

>>阅读原文<<