Flink CheckPoint

结构 #

抽象 #

Checkpoint #

checkpoint 执行过程 #

相关类 #

主流程 #

JobMaster 向 Task 发送触发 checkpoint 消息 #

StreamTask checkpoint #

向下游发送 Barrier #

状态存储后端 #

checkpoint 快照 #

相关类 #

流程 #