Hi all,
I just upgraded storm to 0.9.2-incubating (previously using 0.9.0.1), launched
a simple topology, and got an error related to Netty
Do I have to prepare Netty seperately or is there any reason of exception below?
Any comments would help, thanks in advance.
2014-07-01 15:04:48 b.s.m.n.StormClientErrorHandler [INFO] Connection failed
Netty-Client-some-ip:6703java.nio.channels.UnresolvedAddressException: null
at sun.nio.ch.Net.checkAddress(Net.java:127) ~[na:1.7.0_60] at
sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:644) ~[na:1.7.0_60]
at
org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:140)
~[netty-3.2.2.Final.jar:na] at
org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:103)
~[netty-3.2.2.Final.jar:na] at
org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:60)
~[netty-3.2.2.Final.jar:na] at
org.jboss.netty.channel.Channels.connect(Channels.java:541)
[netty-3.2.2.Final.jar:na] at
org.jboss.netty.channel.AbstractChannel.connect(AbstractChannel.java:218)
[netty-3.2.2.Final.jar:na] at
org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:227)
[netty-3.2.2.Final.jar:na] at
org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:188)
[netty-3.2.2.Final.jar:na] at
backtype.storm.messaging.netty.Client.connect(Client.java:147)
[storm-core-0.9.2-incubating.jar:0.9.2-incubating] at
backtype.storm.messaging.netty.Client.access$000(Client.java:42)
[storm-core-0.9.2-incubating.jar:0.9.2-incubating] at
backtype.storm.messaging.netty.Client$1.run(Client.java:104)
[storm-core-0.9.2-incubating.jar:0.9.2-incubating] at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
[na:1.7.0_60] at
java.util.concurrent.FutureTask.run(FutureTask.java:262) [na:1.7.0_60]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178)
[na:1.7.0_60] at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292)
[na:1.7.0_60] at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
[na:1.7.0_60] at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
[na:1.7.0_60] at java.lang.Thread.run(Thread.java:745) [na:1.7.0_60]
