如何解决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 举报，一经查实，本站将立刻删除。
