我正在运行apachestorm,其中一个节点上设置了nimbus,另外两个节点上设置了两个监控器。启动拓扑(workers=2)后,它无法正确运行。在其中一个supervisor节点的worker日志中,我看到以下错误: 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
工作日志中没有其他错误。如果我用另一个worker(在同一个子网上)替换这些worker中的一个,则拓扑运行得非常好。因此,问题似乎与两个工作节点之间的连接有关。但是,/etc/hosts文件设置正确(与工作进程相同,当与其中一个工作进程正确配对时),两个工作进程可以相互联系(ping/ssh)。nimbus和这些worker之间的连接很好(workers=1的拓扑在每个worker上正确运行)。
我现在不确定这里可能有什么问题。感谢您的帮助。
编辑:
在花了很多时间来解决这个问题之后,我知道在工作节点上不允许连接端口6700。我编辑了iptables以允许端口上的传入tcp连接。工作日志仍然显示一些网络连接错误,但现在,至少拓扑运行良好。 sudo iptables -A INPUT -p tcp --dport 6700 -j ACCEPT
暂无答案!
目前还没有任何答案,快来回答吧!