Apache Strom在随机时间段后重置统计信息

Question

我有一个螺栓和一个喷口的拓扑结构。它运作良好，但有时所有统计数据都消失并从零开始计数。我不重新启动主管，灵气或其他任何东西。这可能是什么原因？

Answer 1

问题在于Storm收到了大量的消息。解决方案是配置topology.max.spout.pending以限制系统中的消息数量。