问题描述
我在 Apaches Storm Cluster 模式下运行了多个查询，有 1 个 Nimbus 和 9 个 Slaves。
由于有多种模式可以运行这样的查询，我最近使用了最直接的一种：storm jar MyTopoplogy.jar main.StartMyTopology。
不幸的是，在提交查询时，在 nimbus.log 中一段时间后，我收到错误：
o.a.s.n.AssignmentdistributionService pool-26-thread-9 [ERROR] Exception to create supervisor client for node 3755c71e-c0f0-4d05-80e4-c872d68fa43f-192.168.24.9: java.lang.RuntimeException: org.apache.storm.thrift.transport.TTransportException: java.net.socketTimeoutException: connect timed out
有趣的是，我所有的元组似乎都处理得很好，我已经仔细检查了我的网络连接和端口。
此外，在 supervisor.log 中，我得到
o.a.s.d.s.Container SLOT_6700 [INFO] Killing 2fb9f9ab-a11a-42e3-b0db-a26e1fd4be6b-192.168.24.4:dc7e49f9-befb-4c11-a41d-9f05c2700f88
o.a.s.d.s.BasicContainer Thread-13 [INFO] Worker Process dc7e49f9-befb-4c11-a41d-9f05c2700f88 exited with code: 143
o.a.s.d.s.Slot SLOT_6700 [INFO] STATE running msInState: 117243 topo:randomQuery-2-1624291418 worker:dc7e49f9-befb-4c11-a41d-9f05c2700f88 -> kill msInState: 3001 topo:randomQuery-2-1624291418 worker:dc7e49f9-befb-4c11-a41d-9f05c2700f88
2021-06-21 16:05:47.750 o.a.s.d.s.Slot SLOT_6700 [INFO] SLOT 6700 all processes are dead...
查找错误代码 143 并不能真正帮到我，所以我一直坚持这个。
有什么想法和想法，为什么我不能创建主管客户端和/或143错误是什么意思？
我使用以下代码运行我的拓扑：
KillOptions killOptions = new KillOptions();
killOptions.set_wait_secs(5);
ArrayList<StormTopology> allTopos = ... // just a list of storm topos
Nimbus.Client client = (Nimbus.Client) NimbusClient.getConfiguredClient(myConfig).getClient();
for (StormTopology topo : allTopos) {
StormSubmitter.submitTopology("test",myConfig,topo);
TimeUnit.MILLISECONDS.sleep(20000);
client.killTopologyWithOpts("test",killOptions);
TimeUnit.MILLISECONDS.sleep(5000);
我可以另外发布我的 Storm Cluster 配置，但我觉得问题出在其他地方...
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）