阿帕奇风暴螺栓到螺栓消息停止或片状

Question

Spout -> Bolt1 -> Bolt2 -> Bolt3 -> Ack originalid(释放队列上的消息)

基本拓扑似乎工作了几分钟，但在某些时候，消息既没有发送也没有消耗，并且从未调用螺栓。我无法判断java线程是否刚刚死亡，因为日志中没有异常或任何表明有问题的迹象。

Apache storm .92或.95对我来说都有相同的结果。

我在storm编程好几年了，从来没有见过这个....

Answer 1

好的，因为我之前的回复被删除了，我将再试一次。我们已经看到了类似的行为，特别是在重载情况下。原来是螺栓速度慢造成的。结果，这个缓慢的进程填满了队列(这通常需要几个小时)，并且在某个时刻，当队列大小足够大时，storm将完全停止处理。