14
4
13
AMLauncherEventType.LAUNCH
RMNodeEvent
RMNodeEventType.STATUS_UPDATE
1
8
SchedulerEventType.APP_ADDED
RMAppAttemptEventType.CONTAINER_ALLOCATED
ApplicationAttemptEventDispatcher
ContainerManagerImpl
16
RMAppEventType.APP_ACCEPTED
10-E1/12-E1
submitJob
RMAppManager
15
3
5
submitApplication
RMContainerEventType.START
ResourceManager
RMAppAttemptEventType.ATTEMPT_NEW_SAVED
RMNodeImpl
registerAppAttempt
allocate
APP_ATTEMPT_ADDED
YarnRunner
12
RMAppEvent
launcherPool
SchedulerEventType.NODE_UPDATE
10
10-E3/12-E3
7
10-E4/12-E4
MRAppMaster
NODE_UPDATE
RMAppImpl
RMStateStoreEventType.STORE_APP_ATTEMPT
NodeEventDispatcher
10-E2/12-E2
nodeHeartbeat
ApplicationMasterService
RMContainer
RMAppAttemptEventType.LAUNCHED
ApplicationEventDispatcher
ContainerLauncher
FifoScheduler
RMStateStoreEventType.STORE_APP
RMAppEventType.START
NodeManager
10-E5/12-E5
EventQueue
AMLivelinessMonitor
Runnable
RMAppAttemptEventType.START
7-1
AMLLauncher
RMAppEventType.ATTEMPT_REGISTERED
11
7-2
RMAppAttemptImpl
6
APP_ADDED
RMAppEventType.APP_NEW_SAVED
RMAppAttemptEventType.REGISTERED
scheduler.allocate为applicationMaster分配容器
registerApplicationMaster
ApplicationMasterLauncher
RMContainerImpl
RMAppAttemptEventType.ATTEMPT_ADDED
ContainerAllocator
scheduler.allocate
Asyn Event Dispatcher
NodeStatusUpdaterImpl
2
SchedulerEventDispatcher
SchedulerEventType.APP_ATTEMPT_ADDED
JobClient
startContainers
ResourceTrackerService
RMAppAttemptEventType
RMStateStore
ClientRMService
