Flink Checkpoint

Flink Checkpoint

CheckpointCoordinator

CheckpointCoordinatorDeActivator

startCheckpointScheduler

ScheduledTrigger（source端的）

triggerCheckpoint

CheckpointStorageLocation

PendingCheckpoint

execution.triggerCheckpoint

RpcTaskManagerGateway

TaskExecutor.triggerCheckpoint

Task.triggerCheckpointBarrier

invokable.triggerCheckpoint

StreamTask.performCheckpoint -> executeCheckpointing ->AsyncCheckpointRunnable 上传到jobmaster

StreamTask

performCheckpoint ->checkpointState-> executeCheckpointing

AsyncCheckpointRunnable -> reportCompletedSnapshotStates上报到jm

state.backend.local-recovery（默认false） mem不支持，only covers keyed state backends

JobMaster

checkpointCoordinatorGateway.acknowledgeCheckpoint

receiveAcknowledgeMessage

completePendingCheckpoint -> finalizeCheckpoint

notifyCheckpointComplete

CheckpointBarrierHandler

BarrierBuffer

getNextNonBlocked

processBarrier

notifyCheckpoint

triggerCheckpointOnBarrier

CheckpointCoordinator 完成checkpoint过程

receiveAcknowledgeMessage SUCCESS

completePendingCheckpoint

pendingCheckpoint.finalizeCheckpoint()

completedCheckpointStore.addCheckpoint(completedCheckpoint)

rememberRecentCheckpointId

dropSubsumedCheckpoints