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

3.12 ResourceManager 分配 Slot
SlotManagerImpl.java

 

 

 

3.13 TaskManager 提供 Slot
TaskExecutor.java

 

 

 

 

JobMaster.java

 

SlotPoolImpl.java

 

 
 
原文地址:https://www.cnblogs.com/qiu-hua/p/14496786.html