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
