1.总体main函数说明

从flink bin目录下解析flink脚本，查看到flink程序入口类：org.apache.flink.client.cli.CliFrontend，
从CliFrontend类中的main开始,执行以下步骤：

  1. 用于打印flink运行过程中的基本信息，包括，代码修订，jvm参数，当前用户，java信息
  2. 查找配置文件所在的目录
  3. 根据配置文件所在目录并加载配置文件
  4. 加载用户自定义命令行参数

image.png

1.1 logEnvironmentInfo 方法 打印flink环境信息

image.png

1.2 getConfigurationDirectoryFromEnv 方法

image.png

1.3 加载配置信息

image.png

1.4 parseParameters 方法真正开始执行

flink的action类型
image.png
具体实现方式
image.png

CliFrontend类型解析了函数入口，以及执行的步骤，接下来根据parseParameters的run方法，具体实现步骤