Flink调度

从提交来一步一步分析,本文源码基于Apache社区 1.8-release 版本 REST提交作业流程: 1.集群启动后 通过 /jars/upload 向集群提交可执行jar文件 2.通过 /jars/:jarid/run 来启动一个job 1.构建并提交JobGraph 我们直接找到WebSubmissionExtension这个类,在StandaloneSession 集群模式下集群初始化D
相关文章
相关标签/搜索