storm和zookeeper的数据交互
总结：
- Nimnus和Supervisor之间通过/storm/supervisor/topology-id对应的数据进行心跳保持。Supervisor在创建这个路径时采用的是临时节点模式，只要Supervisor死掉这个节点就会被删除，Nimbus就会将分配给这个Supervisor的任务重新进行分配
- Worker和Supervisor之间/storm/workbeats/topology-id/node-port中的数据进行心跳的维持，NImbus会每隔一段时间获取该路径下的数据，同时Nimbus还会在它的内存中保存上一次的信息。如果发现某个Worker的心跳信息有一段时间没有更新就认为该worker已经死掉，就会将分配给该Worker的任务重新分配
- Worker和Supervisor之间维持心跳时通过本地文件（基于LocalState）
参考文章：
https://www.cnblogs.com/gulang-jx/p/7419678.html
最后
以上就是留胡子香氛最近收集整理的关于storm在zookeeper中心跳流程的全部内容，更多相关storm在zookeeper中心跳流程内容请搜索靠谱客的其他文章。
本图文内容来源于网友提供，作为学习参考使用，或来自网络收集整理，版权属于原作者所有。
发表评论 取消回复