【Hadoop】Yarn 状态机以及事件机制
原文中文,约7900字,阅读约需19分钟。发表于: 。Yarn采用了基于事件驱动的并发模型,所有状态机都实现了EventHandler接口。事件处理器定义了handle函数,中央处理器AsyncDispatcher实现了Dispatcher接口。事件处理器的注册将事件写入到eventDispatchers中,事件处理通过调用handler函数实现。AsyncDispatcher通过创建线程循环处理接收到的事件。状态转换由成员变量StateMachine管理,所有的StateMachine都由StateMachineFactory进行管理。ResourceManager中的状态机包括RMApp、RMAppAttempt、RMContainer和RMNode。NodeManager中的状态机包括Application、Container和LocalizedResource。