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