Storm 0.9.0.1 中与 Netty 的主管通信

Question

我已经设置了集群 0.9.0.1 版本。

专门的灵气，动物园管理员，两名主管。

不得不说，只要有一位主管，一切都很好。但是当我添加另一个时，来自一台机器的任务无法与另一台机器上的任务通信，因此，消息会超时。

我使用 CentOS 实例在 AWS 上运行一切。我已经为主管安全组打开了所有端口。停止 iptables。但仍然没有运气。

当我执行netstat -a 时，我可以看到服务器之间的ESTABLISHED 连接。我也可以成功ping对方。

不用说 zookeeper 工作正常，我可以运行 echo ruok | nc <ip> 2181 并得到结果。

但是当我检查工作日志时，我看到了这些错误：

2014-03-13 13:53:28 STDIO [ERROR] Mar 13, 2014 1:53:28 PM org.jboss.netty.channel.DefaultChannelPipeline
WARNING: An exception was thrown by a user handler while handling an exception event ([id: 0x4bb68a13] EXCEPTION: java.net.NoRouteToHostException: No route to host)
java.lang.IllegalArgumentException: timeout value is negative
    at java.lang.Thread.sleep(Native Method)
    at backtype.storm.messaging.netty.Client.reconnect(Client.java:94)
    at backtype.storm.messaging.netty.StormClientHandler.exceptionCaught(StormClientHandler.java:118)
    at org.jboss.netty.handler.codec.frame.FrameDecoder.exceptionCaught(FrameDecoder.java:377)
    at org.jboss.netty.channel.Channels.fireExceptionCaught(Channels.java:525)
    at org.jboss.netty.channel.socket.nio.NioClientBoss.processSelectedKeys(NioClientBoss.java:109)
    at org.jboss.netty.channel.socket.nio.NioClientBoss.process(NioClientBoss.java:78)
    at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:312)
    at org.jboss.netty.channel.socket.nio.NioClientBoss.run(NioClientBoss.java:41)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
    at java.lang.Thread.run(Thread.java:744)
2014-03-13 13:53:29 b.s.m.n.StormClientHandler [INFO] Connection failed:
java.net.NoRouteToHostException: No route to host
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[na:1.7.0_51]
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:739) ~[na:1.7.0_51]
    at org.jboss.netty.channel.socket.nio.NioClientBoss.connect(NioClientBoss.java:148) ~[netty-3.6.3.Final.jar:na]
    at org.jboss.netty.channel.socket.nio.NioClientBoss.processSelectedKeys(NioClientBoss.java:104) ~[netty-3.6.3.Final.jar:na]
    at org.jboss.netty.channel.socket.nio.NioClientBoss.process(NioClientBoss.java:78) ~[netty-3.6.3.Final.jar:na]
    at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:312) ~[netty-3.6.3.Final.jar:na]
    at org.jboss.netty.channel.socket.nio.NioClientBoss.run(NioClientBoss.java:41) ~[netty-3.6.3.Final.jar:na]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) [na:1.7.0_51]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) [na:1.7.0_51]
    at java.lang.Thread.run(Thread.java:744) [na:1.7.0_51]

Answer 1

检查每个节点是否都有 /etc/hosts 文件，其中包含对属于集群的主机的所有引用（主机名和 IP）。