JobEventType.JOB_SETUP_COMPLETED
allocate
5
RMContainerEvent
MRAppMaster
4
JobEventType.JOB_START
14
8
startContainers
10
JobEventDispatcher
FiCaSchedulerApp
Asyn Dispatcher
1
3
TaskAttmptEventDispatcher
LaunchedContainerTransition
RequestContainerTransition
7
TaskAttemptEventType.TA_CONTAINER_LAUNCHED
12
2
ApplicationMasterProtocol
RMContainerAllocator
TaskAttemptEventType.TA_SCHEDULE
sendDone
ContainerAssignedTransition
Task
commitPending
registerLaunchedTask
ResourceManager
heartbeat
JobEventType
scheduledRequests
TaskEvent
创建Map&Reduce Tasks
TaskUmbilicalProtocol
ContainerManagerImpl
Map/ReduceTaskImpl
event
ContainerManagementProtocol
CommitterEventHandler
ContainerAllocator.EventType.CONTAINER_REQ
6
13-1
ContainerLauncher.EventType.CONTAINER_REMOTE_LAUNCH
ContainerAllocator.EventType
ApplicationMaster---MRAppMater
FifoScheduler
TaskHeartbeatHandler
TaskAttemptEventType.TA_COMMIT_PENDING / TA_DONE / TA_FAILMSG
EventProcessor
JobEventType.JOB_INIT
TaskAttemptListenerImpl
11
launch
TaskEventType.T_SCHEDULE
TaskAttemptEvent
ContainerStartedTransition
13-2
NodeManager
scheduleTasks
9
handle
TaskEventType.T_ATTEMPT_LAUNCHED
ApplicationMasterService
ContainerLauncherImpl
CONTAINER_REMOTE_LAUNCH
TaskAttemptEventType.TA_ASSIGNED
JobImpl
serviceStart
fsError
TaskAttmptImpl
CommitterEventType.JOB_SETUP
getResources
TaskEventDispatcher
CommitterEvent
RMContainerImpl
RMContainerEventType.START
