Apache Storm停止执行特定螺栓

问题描述

我有一个带有1个喷口和3个螺栓的拓扑，当前在本地模式下运行。

spout-> Read from kafka
bolt1-> extract necessary fields from kafka data
bolt2 -> store and interact with redis for the received data
bolt3-> write the processed data into cassandra

当我开始运行拓扑时，我发现一段时间后风暴停止了第二个螺栓（bolt2）的执行。 我在控制台中收到以下消息：

14:06:54.939 [Thread-35-RedisBolt-executor[5,5]] INFO  o.a.s.u.Utils - Async loop interrupted!
14:06:54.939 [SLOT_1027] INFO  o.a.s.e.ExecutorShutdown - Shut down executor RedisBolt:[5,5]
14:06:54.939 [SLOT_1027] INFO  o.a.s.e.ExecutorShutdown - Shutting down executor UserSpout:[4,4]
14:06:55.006 [Thread-36-UserSpout-executor[4,4]] INFO  o.a.k.c.c.i.AbstractCoordinator - Marking the coordinator 10.5.30.79:9092 (id: 2147483647 rack: null) dead for group queue-1
14:06:55.184 [Thread-36-UserSpout-executor[4,4]] INFO  o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 10.5.30.79:9092 (id: 2147483647 rack: null) for group queue-1.

如消息所示，它仅关闭了我的第二个螺栓（即redis螺栓）和喷嘴。在此消息之后，我的第一个螺栓（bolt1）的打印语句仍然出现。我无法确定可能是什么原因。有人可以帮忙吗？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）