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

3.8 JobManager 申请 Slot

3.8.1 启动 SlotPool

接 3.6，JobMaster 启动时，启动 SlotPool，向 ResourceManager 注册 

3.8.2 向 ResourceManager 注册

经过下面层层调用：

 

 

RegisteredRpcConnection.java 

JobMaster.java 的内部类 ResourceManagerConnection 

 

3.8.2 SlotPool 申请 slot

注册成功调用 onRegistrationSuccess(), 向 ResourceManager 进行 slot 的申请:

JobMaster.java 的内部类 ResourceManagerConnection 

SlotPoolImpl.java

ResourceManager.java ： 由 ResourceManager 里的 SlotManager 处理请求 

 

SlotManagerImpl.java

3.9 ResourceManager 申请资源

ResourceManager.java

 

 

YarnResourceManagerDriver.java