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

3.10 TaskManager 启动

YarnTaskExecutorRunner.java

 

TaskManagerRunner.java

 

 

TaskExecutorToServiceAdapter.java

TaskExecutor.java

3.11 向 ResourceManager 注册

TaskExecutor.java

 

TaskExecutorToResourceManagerConnection.java

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

TaskExecutorToResourceManagerConnection.java 的内部类 ResourceManagerRegistration

注册成功调用 onRegistrationSuccess

TaskExecutor.java 的内部类 ResourceManagerRegistrationListener

 

ResourceManager.java

SlotManagerImpl.java