Checkpoint的实现原理 #

相关类 #

CheckpointCoordinator #

Execution #

Actions #

Callback #

Checkpoint的整体设计 #

开启Checkpoint #

流程 #

Checkpoint的触发过程 #

通过CheckpointCoordinator触发 #

流程 #

创建PendingCheckpoint #

快照任务状态 #

流程 #

takeSnapshotSync() #

通过对齐CheckpointBarrier触发 #

在StreamTask中执行Checkpoint #

发送AcknowledgeCheckpoint消息到CheckpointCoordinator中 #