Flink 源码(四):Flink 环境准备及提交流程(一)
时间:2022-05-11 09:05
0 简介
Yarn-per-job模式提交流程 总图1 程序起点
2 创建 Yarn 客户端应用程序
2.1 程序入口
2.2 解析输入参数
2.3 选择创建哪种类型的客户端
2.4 获取有效配置
2.5 调用用户代码的 main 方法 2.6 调用执行环境的 execute 方法
时间:2022-05-11 09:05
2.1 程序入口
2.2 解析输入参数
2.3 选择创建哪种类型的客户端
2.4 获取有效配置
2.5 调用用户代码的 main 方法 2.6 调用执行环境的 execute 方法