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

 

 

   

标签：java,注册,ResourceManager,流程,Flink,TaskExecutorToResourceManagerConnection,提交,Task
来源： https://www.cnblogs.com/qiu-hua/p/14496727.html