Flink Checkpoint
2023-04-12 11:00:47 0 举报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
0 条评论
下一页
