4

我正在运行 Apache Storm,在一个节点上设置了 Nimbus,在另外两个节点上设置了两个主管。在我启动拓扑(worker=2)后,它无法正常运行。在其中一个主管节点的工作日志中,我看到以下错误:

2018-07-04 17:36:02.650 o.a.s.m.n.Client client-boss-1 [ERROR] connection attempt 1 to Netty-Client-hostname/X.X.X.X:6700 failed: org.apache.storm.shade.org.jboss.netty.channel.ConnectTimeoutException: connection timed out: hostname/X.X.X.X:6700

在另一个工作节点上,我看到以下错误: 2018-07-04 17:34:11.344 o.a.s.m.n.Client client-boss-1 [ERROR] connection attempt 3 to Netty-Client-hostname1/X.X.X.X:6700 failed: java.net.ConnectException: Connection refused: hostname1/X.X.X.X:6700

工作人员日志中没有其他错误。如果我用另一个工人(在同一个子网上)替换这些工人之一,拓扑运行完美。因此,问题似乎与两个工作节点之间的连接有关。但是,/etc/hosts 文件设置正确(与与其中一个正确工作的工作人员相同)并且两个工作人员可以相互访问(ping/ssh)。nimbus 和这些工人之间的连接很好(worker=1 的拓扑在这些工人中的每一个上都正确运行)。

我现在不确定这里可能是什么问题。任何帮助表示赞赏。

编辑:

在花了很多时间弄清楚这一点之后,我才知道在工作节点上不允许端口 6700 上的连接。我编辑了 iptables 以允许端口上的传入 tcp 连接。工作日志仍然显示一些网络连接错误,但现在,至少,拓扑运行良好。

sudo iptables -A INPUT -p tcp --dport 6700 -j ACCEPT

4

0 回答 0