Flink CheckPoint详细过程

Checkpoint由JM的Checkpoint Coordinator发起 第一步，Checkpoint Coordinator 向所有 source 节点 trigger Checkpoint；。 第二步，source 节点向下游广播 barrier，这个 barrier 就是实现 Chandy-Lamport 分布式快照算法的核心，下游的 task 只有收到所有 input 的 barrie

>>阅读原文<<