- 创建RMAppImpl对象;发送RMAppEventType.START事件
- RMAppImpl收到RMAppEventType.START后,触发执行RMAppImpl.RMAppNewlySavingTransition.transition()方法,在该方法内部会触发RMStateStoreAppEvent.STORE_APP事件,RMStateStore收到RMStateStoreAppEvent.STORE_APP事件后,触发执行RMStateStore.StoreAppTransition.transition()方法,在该方法内部会将app的状态保存到zk中,RMStateStoreState状态从ACTIVE转变为FENCED(该状态机后续补充)
- 状态保存完成后,在RMStateStore.StoreAppTransition.transition()方法中会触发RMAppEventType.APP_NEW_SAVED事件
- RMAppImpl收到RMAppEventType.APP_NEW_SAVED事件后,触发执行RMAppImpl.AddApplicationToSchedulerTransition.transition()方法,在该方法内部会触发SchedulerEventType.APP_ADDED事件,此时RMAppImpl状态由NEW_SAVING转变为SUBMITTED。
- CapacityScheduler收到SchedulerEventType.APP_ADDED事件后,执行handle方法(没有进入状态机),做了哪些操作待整理,触发RMAppEventType.APP_ACCEPTED事件
- RMAppImpl收到RMAppEventType.APP_ACCEPTED事件,触发执行RMAppImpl.StartAppAttemptTransition.transition()方法,在该方法内部会创建RMAppAttemptImpl对象,并触发RMAppAttemptEventType.START事件,此时RMAppImpl状态由SUBMITTED转变为ACCEPTED。
- RMAppAttemptImpl收到RMAppAttemptEventType.START事件后,触发执行RMAppAttemptImpl.AttemptStartedTransition.transition()方法,在该方法中执行注册这一次尝试信息的操作(在appAttempt.masterService.responseMap中加入该信息),另外的操作待补充;触发SchedulerEventType.APP_ATTEMPT_ADDED事件,此时RMAppAttemptImpl的状态从NEW转变为SUBMITTED状态。
- CapacityScheduler收到SchedulerEventType.APP_ATTEMPT_ADDED事件,执行handler方法:将applicationAttempt提交到队列中,具体操作细节待补充;触发RMAppAttemptEventType.ATTEMPT_ADDED事件。
- RMAppAttemptImpl收到RMAppAttemptEventType.ATTEMPT_ADDED事件,触发执行RMAppAttemptImpl.ScheduleTransition.transition()方法,在该方法内部经过一系列操作(待整理),会最终触发RMContainerEventType.ACQUIRED事件(这个调用有点深,具体路径为CapacityScheduler.allocate()、FicaSchedulerApp.getAllocation()、pullNewlyAllocatedContainers()、updateContainerAndNMToken())。此时RMAppAttemptImpl的状态从SUBMITTED转变为SCHEDULED状态。
https://blog.csdn.net/weixin_35792948/article/details/86351117
|