同步方法在做什么？心跳元组的频率是多少？

Question

我使用的是Storm0.9.3，使用的是Python。在

我指的是Multilang-protocol。在

谁能解释一下：

• 这个sync()在做什么？
• 心跳元组的频率是多少？

Answer 1

Storm0.9.3引入了multilang子进程heartbeat。（实际上是我介绍的。）

如您所知，nimbus和主管检查工人的心跳，并在工人未及时写入心跳时采取适当措施。在

Multilang子进程heartbeat也在做类似的事情，但它使用Multilang协议而不是ZK。在

1. 在0.9.3之前，sync（）只用于外壳喷口，以通知子进程next（）的执行已完成。在0.9.3之后，Storm为sync（）添加了新的含义，“heartbeat”（表示通知我没事）。

2. ShellSpout不发送heartbeat元组，因为正常情况下Spoutt的nextTuple（）被频繁调用，子进程的next（）也被频繁调用。ShellBolt每1秒向子进程发送心跳元组。

希望这有帮助。在