Dispatcher
submitJob
persistAndRunJob
createJobManagerRunner & startJobManagerRunner
grantLeadership
verifyJobSchedulingStatusAndStartJobManager
JobManagerRunnerFactory
JobManagerRunner
LibraryCacheManager registerJob
JobMasterFactory.createJobMasterService
start
verifyJobSchedulingStatusAndStartJobManager
JobMaster
构造器 createExecutionGraph
ExecutionGraphBuilder.buldGraph
start startJobExecution
ExecutionGraph
enableCheckpointing
CheckpointCoordinator
createActivatorDeactivator
scheduleForExecution
scheduleEager
Execution.deploy
TaskExecutor
submitTask
Task.run invokable.invoke();
