您的位置: 首页 > IT文章 > Flink 源码（十五）:Flink 环境准备及提交流程（六）yarn-per-job 提交流程（四）

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

分类: IT文章 • 2023-11-23 22:38:43

3.8 JobManager 申请 Slot

3.8.1 启动 SlotPool

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

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

3.8.2 向 ResourceManager 注册

经过下面层层调用：

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

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

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

RegisteredRpcConnection.java

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

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

JobMaster.java 的内部类 ResourceManagerConnection

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

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

3.8.2 SlotPool 申请 slot

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

JobMaster.java 的内部类 ResourceManagerConnection

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

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

SlotPoolImpl.java

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

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

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

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

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

SlotManagerImpl.java

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

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

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

3.9 ResourceManager 申请资源

ResourceManager.java

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

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

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

YarnResourceManagerDriver.java

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

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