Storm 流程分析

流程说明 client提交topology到nimbusweb nimbus针对该topology创建本地的目录,nimbus中的调度器根据topology的配置计算task,并把task分配到不一样的worker上,调度的结果写入zk。svg 在zk上建立assignments节点,存储task和supervisor中work的对应关系。 在zk上建立workerbeats节点来监控worker
相关文章
相关标签/搜索