JStorm源码分析(五)Supervisor获取任务
JStorm源码分析(五):Supervisor获取任务
JStorm源码分析文件
对于整个JStorm源码分析系列，我将JStorm源码分析的文件放在我的GitHub上JStorm源码剖析,欢迎大家fork和star
1.在Supervisor的启动过程中，即在mkSupervisor()方法中，源码如下:
SyncSupervisorEvent会定时的循环扫描Zookeeper的任务分配目录，看是否有自己的任务，如果 有，那么把对应的信息写到本地(Supervisor)机器的指定目录中，这个工作主要是有 SyncSupervisorEvent 线程中的run方法来完成的。
2.SyncSupervisorEvent 的成员信息
3.任务配置信息Assignment对象所包含的相关信息
3.SyncSupervisorEvent 的run()方法
4.getAllAssignments()获取所有的任务信息，放入本地库中
5.syncProcesses.run(zkAssignment, downloadFailedTopologyIds)
相关系列文章
JStorm源码分析(六)Supervisor启动Worker的过程
微信公众号
有兴趣的同学可以关注小编哟!