主管通信風暴0.9.0.1與Netty

我已經設置了集羣0.9.0.1版本。主管通信風暴0.9.0.1與Netty

專門的靈氣，動物園管理員，兩位主管。不得不說，一位主管一切正常。但是當我添加另一臺機器時，來自一臺機器的任務無法與另一臺機器上的任務進行通信，因此消息正在超時。

我使用CentOS實例在AWS上運行所有內容。我將爲管理員安全組打開所有端口。禁用iptables。但仍然沒有運氣。

當我做netstat -a我可以看到ESTABLISHED服務器之間的連接。我也可以互相成功ping。

不需要說動物園管理員工作正常，我可以運行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]

來源

2014-03-13 Vor

你的storm.yaml文件的內容是什麼？你能從所有主機ping它的IP嗎？ – bridiver

檢查每個節點的/ etc/hosts文件中的所有引用（主機名和IP）寫入到主機屬於羣。

來源

2014-03-20 19:09:19 wizard86

主管通信風暴0.9.0.1與Netty

回答

相關問題