Flink調度

從提交來一步一步分析,本文源碼基於Apache社區 1.8-release 版本 REST提交作業流程: 1.集羣啓動後 通過 /jars/upload 向集羣提交可執行jar文件 2.通過 /jars/:jarid/run 來啓動一個job 1.構建並提交JobGraph 我們直接找到WebSubmissionExtension這個類,在StandaloneSession 集羣模式下集羣初始化D
相關文章
相關標籤/搜索