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

3.6 Dispatcher 启动 JobManager

Dispatcher.java

Dispatcher.java

 

JobManagerRunnerImpl.java

StandaloneLeaderElectionService.java 

JobManagerRunnerImpl.java 

 

JobMaster.java

 

3.7 ResourceManager 启动 SlotManager

ResourceManager.java

3.7.1 创建 Yarn 的 RM 和 NM 客户端

ActiveResourceManager.java

AbstractResourceManagerDriver.java 

YarnResourceManagerDriver.java

 

3.7.2 启动 SlotManager

StandaloneLeaderElectionService.java

ResourceManager.java

 

 

SlotManagerImpl.java