Flink 源码（四）:Flink 环境准备及提交流程（一）程序起点与创建 Yarn 客户端应用程序

0 简介

Yarn-per-job模式提交流程 总图

1 程序起点

1）flinkinflink

　　　　=> exec  $JAVA_RUN  $JVM_ARGS  "${log_setting[@]}"  -classpath  "`manglePathList　"$CC_CLASSPATH:$INTERNAL_HADOOP_CLASSPATHS"`"

org.apache.flink.client.cli.CliFrontend "$@"

2）flink/bin/config.sh(相关环境配置都在这里)

　　=> JAVA_RUN=java

　　=> JVM_ARGS=""　　=> # Use conf/flink-conf.yaml

　　=>INTERNAL_HADOOP_CLASSPATHS="${HADOOP_CLASSPATH}:${HADOOP_CONF_DIR}:${YARN_CONF_DIR}"

3）执行 java -cp 就会开启 JVM 虚拟机，在虚拟机上开启 CliFrontend 进程，然后开始执行main 方法

　　说明：java -cp 和 -classpath 一样，是指定类运行所依赖其他类的路径。

　　java -cp =》开启 JVM 虚拟机 =》开启 Process（CliFrontend）=》程序入口 CliFrontend.main

4）Flink 提交任务的入口类为 CliFrontend。找到这个类的 main 方法：

　　在 IDEA 中全局查找（ctrl + n）：org.apache.flink.client.cli.CliFrontend，找到 CliFrontend类，并找到 main 方法

2 创建 Yarn 客户端应用程序

2.1 程序入口

CliFrontend.java 

 

 

 

2.2 解析输入参数

CliFrontend.java 

 

 

DefaultParser.java

DefaultParser.java 

 

 

 

 

各种情况的解析，逻辑大体相同：去除-或--前缀，校验参数，以其中一个为例

Options.java：

 

DefaultParser.java