Flink submitJob
2019-08-26 15:42:49 1 举报AI智能生成
Flink 提交任务源码跟踪 便于记忆
作者其他创作
大纲/内容
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();
0 条评论
下一页
