Flink 源码（十三）:Flink 环境准备及提交流程（四）yarn-per-job 提交流程（二）

3.4 提交应用

接下来是向 yarn 提交，略过：

YarnClientImpl.java

ApplicationClientProtocolPBClientImpl.java

ApplicationClientProtocolPBServiceImpl.java

ClientRMService.java

 

3.5 创建 Dispatcher、ResourceManager

Per-job 模式的 AM container 加载运行入口是 YarnJobClusterEntryPoint 中的 main()方法

YarnJobClusterEntrypoint.java

 

ClusterEntrypoint.java

 

 

DefaultDispatcherResourceManagerComponentFactory.java

 

 

 

 

 

3.5.1 创建 YarnResourceManager

ResourceManagerFactory.java

 

YarnResourceManagerFactory.java

 

创建 YarnResourceManager 时，创建了 SlotManager

ResourceManagerFactory.java

ResourceManagerRuntimeServices.java

3.5.2 创建并启动 Dispatcher

DefaultDispatcherRunnerFactory.java

DefaultDispatcherRunner.java

 

DispatcherRunnerLeaderElectionLifecycleManager.java

 

StandaloneLeaderElectionService.java

DefaultDispatcherRunner.java 

AbstractDispatcherLeaderProcess.java

JobDispatcherLeaderProcess.java

 

3.5.3 启动 ResourceManager

DefaultDispatcherResourceManagerComponentFactory.java

ResourceManager.java