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

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

分类: IT文章 • 2023-11-23 22:34:07

3.10 TaskManager 启动

YarnTaskExecutorRunner.java

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

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

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

TaskManagerRunner.java

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

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

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

TaskExecutorToServiceAdapter.java

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

TaskExecutor.java

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

3.11 向 ResourceManager 注册

TaskExecutor.java

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

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

TaskExecutorToResourceManagerConnection.java

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

开始注册 newRegistration. startRegistration()会调用 invokeRegistration():

TaskExecutorToResourceManagerConnection.java 的内部类 ResourceManagerRegistration

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

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

注册成功调用 onRegistrationSuccess

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

TaskExecutor.java 的内部类 ResourceManagerRegistrationListener

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

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

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

ResourceManager.java

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

SlotManagerImpl.java

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

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

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