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

3.12 ResourceManager 分配 Slot

SlotManagerImpl.java

 

 

 

3.13 TaskManager 提供 Slot

TaskExecutor.java

 

 

 

 

JobMaster.java

 

SlotPoolImpl.java