flink checkpoint

1 原理 flink通過checkpoint來進行狀態保存，可以保證Flink集羣在某個算子因爲某些原因(如 異常退出)出現故障時，能夠將整個應用流圖的狀態恢復到故障之前的某一狀態，   保證應用流圖狀態的一致性。 Flink的checkpoint機制原理來自「Chandy-Lamport algorithm」算法，通過checkpoint頻率時間定時發送barrier消息。 (分佈式快照算)  

>>阅读原文<<