本文主要是介绍Flink1.10任务提交流程分析(二)，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
YarnJobClusterExecutor
接着上篇的分析，任务最终提交是交给PipelineExecutor来execute，PipelineExecutor的选择是根据不同的提交模式来决定即execution.target参数来决定，对于yarn-per-job会选择YarnJobClusterExecutor类型的executor。
public class YarnJobClusterExecutor extends AbstractJobClusterExecutor<ApplicationId, YarnClusterClientFactory> {public static final String NAME = "yarn-per-job";public YarnJobClusterExecutor() {super(new YarnClusterClientFactory());}
}
其实现比较简单，比较重要其构造器中YarnClusterClientFactory，用于创建YarnClusterDescriptor
这篇关于Flink1.10任务提交流程分析(二)的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
