1.总体main函数说明
从flink bin目录下解析flink脚本,查看到flink程序入口类:org.apache.flink.client.cli.CliFrontend,
从CliFrontend类中的main开始,执行以下步骤:
- 用于打印flink运行过程中的基本信息,包括,代码修订,jvm参数,当前用户,java信息
- 查找配置文件所在的目录
- 根据配置文件所在目录并加载配置文件
- 加载用户自定义命令行参数
1.1 logEnvironmentInfo 方法 打印flink环境信息
1.2 getConfigurationDirectoryFromEnv 方法
1.3 加载配置信息
1.4 parseParameters 方法真正开始执行
flink的action类型
具体实现方式
CliFrontend类型解析了函数入口,以及执行的步骤,接下来根据parseParameters的run方法,具体实现步骤