1.概述
转载:Flink 源码之快照
2.周期触发checkpoint的方法调用链
JobMaster.triggerSavepoint
SchedulerBase.startCheckpointScheduler
CheckpointCoordinator.startCheckpointScheduler
CheckpointCoordinator.scheduleTriggerWithDelay
CheckpointCoordinator
微信扫一扫
转载:Flink 源码之快照
JobMaster.triggerSavepoint
SchedulerBase.startCheckpointScheduler
CheckpointCoordinator.startCheckpointScheduler
CheckpointCoordinator.scheduleTriggerWithDelay
CheckpointCoordinator
相关推荐