Flink CheckPoint詳細過程

Checkpoint由JM的Checkpoint Coordinator發起 第一步，Checkpoint Coordinator 向所有 source 節點 trigger Checkpoint；。 第二步，source 節點向下遊廣播 barrier，這個 barrier 就是實現 Chandy-Lamport 分佈式快照算法的核心，下游的 task 只有收到所有 input 的 barrie

>>阅读原文<<