您的位置:首页 > 其它

Spark系列(六)Master注册机制和状态改变机制

2016-11-15 10:06 218 查看
各组件的注册流程如下图:

注册机制源码说明:
入口:org.apache.spark.deploy.master文件下的receiveWithLogging方法中的case RegisterApplication(注册Application)、case RegisterWorker(注册Worker)、case RequestSubmitDriver(注册Driver).
 
状态改变机制源码分析:
入口:org.apache.spark.deploy.master文件下的receiveWithLogging方法中的DriverStateChanged(Driver状态改变处理)、ExecutorStateChanged(Executor状态改变处理)。

状态改变处理流程图


内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: