本文主要是介绍Flink1.10任务提交流程分析(一),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
Flink任务常见的提交方式通过flink run命令方式提交,如果我们想自己通过API方式实现任务提交,那么就需要了解flink run执行过程,本篇主要透过源码分析其提交流程。(注:基于1.10.1分析)
提交入口
查看bin/flink脚本可以看到提交入口类为:org.apache.flink.client.cli.CliFrontend,传入的参数就是flink 命令后面的参数,查看main方法:
public static void main(final String[] args) {EnvironmentInformation.logEnvironmentInfo(LOG, "Command Line Client", args);// 1. $FLINK_HOME/conffinal String configurationDirectory = getConfigurationDirectoryFromEnv();// 2. 加载flink-conf.yamlfinal Configuration configuration = Global
这篇关于Flink1.10任务提交流程分析(一)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!