Flink submitJob

Flink submitJob

RestClusterClient

submitJob(JobGraph)

create jobGraphFile

JobSubmitRequestBody

submissionFuture

JobSubmitHeader 

DispatcherRestEndpoint

JobSubmitHandler handle

loadJobGraph

getJarFilesToUpload

getArtifactFIlesToUpload

submitJob

Dispatcher

persistAndRunJob

createJobManagerRunner & startJobManagerRunner

grantLeadership

verifyJobSchedulingStatusAndStartJobManager

JobManagerRunnerFactory

JobManagerRunner

LibraryCacheManager registerJob

JobMasterFactory.createJobMasterService

start

JobMaster

构造器 createExecutionGraph

ExecutionGraphBuilder.buldGraph

start startJobExecution

ExecutionGraph

enableCheckpointing

CheckpointCoordinator

createActivatorDeactivator

scheduleForExecution

scheduleEager

Execution.deploy

TaskExecutor

submitTask

Task.run invokable.invoke();