解决“org.apache.storm.thrift.transport.TTransportException”

如何解决解决“org.apache.storm.thrift.transport.TTransportException”

我在 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 配置，但我觉得问题出在其他地方...