本文主要是介绍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任务提交流程分析(二)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!