从对storm的描述来看,它是基于zookeeper的,只要工作节点死亡,就可以从zookeeper恢复并获取其状态。有人知道这是怎么做到的吗?明确地如何恢复发生故障的工作节点?Zookeeper如何保持它的状态。另外,每个区域只能存储少量的数据。
vvppvyoh1#
你说的是工人还是主管?每个storm worker节点运行一个storm“supervisor”守护进程,该守护进程管理工作进程。如果nimbus和supervisor守护进程出现异常,您需要设置supervisory(比如daemontools或supervisord,这与storm supervisors无关)来监视和重新启动它们。nimbus和supervisors都是快速失败和无状态的。zookepeer用于nimbus和监管者之间的协调,同时保存状态信息,这些信息保存在ZookeKeeper或磁盘上,以免丢失状态信息。状态数据不是很大,zookeeper也应该在监督下运行。请检查此项以了解更多容错详细信息。
1条答案
按热度按时间vvppvyoh1#
你说的是工人还是主管?每个storm worker节点运行一个storm“supervisor”守护进程,该守护进程管理工作进程。
如果nimbus和supervisor守护进程出现异常,您需要设置supervisory(比如daemontools或supervisord,这与storm supervisors无关)来监视和重新启动它们。nimbus和supervisors都是快速失败和无状态的。zookepeer用于nimbus和监管者之间的协调,同时保存状态信息,这些信息保存在ZookeKeeper或磁盘上,以免丢失状态信息。
状态数据不是很大,zookeeper也应该在监督下运行。
请检查此项以了解更多容错详细信息。