java - storm 0.9.0.1 与 Netty 的 supervisor 通信

Question

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

专用灵气、动物园管理员、两名主管。

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

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

当我做 netstat -a我可以看到 ESTABLISHED服务器之间的连接。我也可以成功ping彼此。

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

但是当我检查 worker 日志时，我看到了这些错误:

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)。