Flink 源码（十二）:Flink 环境准备及提交流程（三）yarn-per-job 提交流程（一）

3 yarn-per-job 提交流程

AbstractJobClusterExecutor.java

3.1 启动 yarn 客户端

YarnClusterClientFactory.java

3.2 获取集群配置参数

AbstractContainerizedClusterClientFactory.java

3.3 部署集群

YarnClusterDescriptor.java

3.3.1 上传 jar 包和配置文件到 HDFS

YarnClusterDescriptor.java

 

 

 

 

 

 

 3.3.2 封装 AM 参数和命令

YarnClusterDescriptor.java

 

 

封装 AM 参数，提交应用：