1

如何让storm-nimbus在同一台机器上重新启动worker?

为了测试容错性,我在一个工作进程上执行了 kill -9,期望工作进程在同一台机器上重新启动,但是在其中一台机器上,nimbus 在另一台机器上启动了工作进程!!!Nimbus 日志没有显示多次尝试或任何异常或错误!

将不胜感激任何帮助,谢谢!

4

1 回答 1

1

你不应该需要。工作人员应该能够切换到任何主管的空位。如果你有一个不适应这个的螺栓,因为它正在读取特定主管的数据,这是一个设计问题。

此外,Storm 的容错不仅可以处理 worker 故障,还可以处理 supervisor 故障,在这种情况下,您将无法在同一个 supervisor 上重新启动 worker。您不必担心工人在哪里:这是 Storm 的一个特性。

于 2013-11-17T17:13:40.033 回答