You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Carmen Molatch <Ca...@jeppesen.com> on 2016/06/17 16:30:55 UTC
netty.client can't communicate with workers in EC2 instances in AWS

The intercommunication between the workers fails in EC2 instances.  I have a master VM with nimbus and ui and three supervisor VMs with 8 workers each.

Has somebody encountered the same issue?  If so, how can it be resolved?  Thanks
Error
2016-06-17T16:00:47.641+0000 b.s.m.n.Client [ERROR] connection attempt 8 to Netty-Client-ip-10-xx-xx-xx:6704 failed: java.lang.RuntimeException: Returned channel was actually not established
2016-06-17T16:00:47.641+0000 b.s.m.n.Client [INFO] connection attempt 9 to Netty-Client-ip-10-xx-xx-xx:6704 scheduled to run in 356 ms
2016-06-17T16:00:47.998+0000 b.s.m.n.StormClientErrorHandler [INFO] Connection failed Netty-Client-ip-10-xx-xx-xx:6704
java.nio.channels.UnresolvedAddressException: null
        at sun.nio.ch.Net.checkAddress(Net.java:123) ~[na:1.8.0_25]
        at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:621) ~[na:1.8.0_25]
        at org.apache.storm.netty.channel.socket.nio.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:108) [storm-core-0.9.5.jar:0.9.5]
        at org.apache.storm.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:70) [storm-core-0.9.5.jar:0.9.5]
        at org.apache.storm.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendDownstream(DefaultChannelPipeline.java:779) [storm-core-0.9.5.jar:0.9.5]
        at org.apache.storm.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54) [storm-core-0.9.5.jar:0.9.5]
        at org.apache.storm.netty.channel.DefaultChannelPipeline.sendDownstream(DefaultChannelPipeline.java:591) [storm-core-0.9.5.jar:0.9.5]
        at org.apache.storm.netty.channel.DefaultChannelPipeline.sendDownstream(DefaultChannelPipeline.java:582) [storm-core-0.9.5.jar:0.9.5]
        at org.apache.storm.netty.channel.Channels.connect(Channels.java:634) [storm-core-0.9.5.jar:0.9.5]
        at org.apache.storm.netty.channel.AbstractChannel.connect(AbstractChannel.java:207) [storm-core-0.9.5.jar:0.9.5]
        at org.apache.storm.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:229) [storm-core-0.9.5.jar:0.9.5]
        at org.apache.storm.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:182) [storm-core-0.9.5.jar:0.9.5]
        at backtype.storm.messaging.netty.Client$Connector.call(Client.java:612) [storm-core-0.9.5.jar:0.9.5]
        at backtype.storm.messaging.netty.Client$Connector.call(Client.java:595) [storm-core-0.9.5.jar:0.9.5]
        at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_25]
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_25]
        at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_25]
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) [na:1.8.0_25]
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) [na:1.8.0_25]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_25]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_25]
        at java.lang.Thread.run(Thread.java:745) [na:1.8.0_25]

Carmen