Flink Checkpoint

source operator task2

D

得到2个CB，则认为本次的checkoutpoint是成功的

sink operator task1

checkout point

Flink 的 Checkpoint 机制就是依靠 Chandy-Lamport 算法进行设计实现

CB

Flink Checkpoint

sum operator task2

汇报

CheckpointCoordinator

task state 持久化

JobManger

可部分重发的数据源

数据源

CB，id=1time+n

source operator task1

 检查点机制 

CB，id=1time

sum operator task1