3.8 JobManager 申请 Slot
3.8.1 启动 SlotPool
接 3.6,JobMaster 启动时,启动 SlotPool,向 ResourceManager 注册
![](https://img2020.cnblogs.com/blog/1275415/202103/1275415-20210307201533213-536141713.png)
3.8.2 向 ResourceManager 注册
经过下面层层调用:
![](https://img2020.cnblogs.com/blog/1275415/202103/1275415-20210307201758837-1738902966.png)
RegisteredRpcConnection.java
![](https://img2020.cnblogs.com/blog/1275415/202103/1275415-20210307201937838-698637024.png)
JobMaster.java 的内部类 ResourceManagerConnection
![](https://img2020.cnblogs.com/blog/1275415/202103/1275415-20210307202125418-833021774.png)
3.8.2 SlotPool 申请 slot
注册成功调用 onRegistrationSuccess(), 向 ResourceManager 进行 slot 的申请:
JobMaster.java 的内部类 ResourceManagerConnection
![](https://img2020.cnblogs.com/blog/1275415/202103/1275415-20210307202439488-2127147170.png)
SlotPoolImpl.java
![](https://img2020.cnblogs.com/blog/1275415/202103/1275415-20210307202541487-1604619843.png)
ResourceManager.java : 由 ResourceManager 里的 SlotManager 处理请求
![](https://img2020.cnblogs.com/blog/1275415/202103/1275415-20210307202705843-288552790.png)
SlotManagerImpl.java
![](https://img2020.cnblogs.com/blog/1275415/202103/1275415-20210307202829083-83947963.png)
3.9 ResourceManager 申请资源
ResourceManager.java
![](https://img2020.cnblogs.com/blog/1275415/202103/1275415-20210307203158805-759188672.png)
YarnResourceManagerDriver.java
![](https://img2020.cnblogs.com/blog/1275415/202103/1275415-20210307203351861-447926625.png)