Re: Storm supervisor throwing exception - java.nio.channels.UnresolvedAddressException

2014-09-15 Thread Yuri Kostin
Try adding IPs and host names to your /etc/hosts on all servers so all servers 
can find one another by hostname.

On Sep 15, 2014, at 2:22 AM, Ayush Vatsyayan  wrote:

> Hi,
> 
> I'm trying to run a multicluster storm setup. I've three machines, of which 
> 1st one executes zookeeper, nimbus, and storm ui, while on 2nd and 3rd I'm 
> running two supervisors.
> 
> When I look at the supervisor logs, I'm getting following error
> b.s.m.n.StromClientErrorHandler [Info] Connection failed 
> Netty-Client-:6700
> java.nio.channels.UnresolvedAddressException: null
> at sun.nio.ch.Net.checkAddress(Net.java:85) ~[na:1.7.0_17]
> at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:597) 
> ~[na:1.7.0_17]
> at 
> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:106)
>  ~[ne$
> at 
> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:69)
>  ~[n$
> at 
> org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54)
>  ~[netty-3.6.3.Fina$
> at org.jboss.netty.channel.Channels.connect(Channels.java:634) 
> [netty-3.6.3.Final.jar:na]
> at 
> org.jboss.netty.channel.AbstractChannel.connect(AbstractChannel.java:207) 
> [netty-3.6.3.Final.jar:na]
> at 
> org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:229) 
> [netty-3.6.3.Final.jar:na]
> at 
> org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:182) 
> [netty-3.6.3.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-incubatin$
> 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_17]
> at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334) 
> [na:1.7.0_17]
> at java.util.concurrent.FutureTask.run(FutureTask.java:166) 
> [na:1.7.0_17]
> at 
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:$
> at 
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292)
>  [n$
> at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
>  [na:1.7.0_17]
> at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>  [na:1.7.0_17]
> at java.lang.Thread.run(Thread.java:722) [na:1.7.0_17]
> 
> I tried to telnet on the machine (telnet  
> 6700) with ipaddress it works fine, but not with the hostname of the other 
> supervisor (telnet says unknown host).
> 
> Any help is really appreciable. 
> 
> Many thanks,
> Ayush V.
> 



Re: Storm supervisor throwing exception - java.nio.channels.UnresolvedAddressException

2014-09-15 Thread Ayush Vatsyayan
Thanks Yori Kostin for the quick reply - much appreciated. It solved the
problem.

On Mon, Sep 15, 2014 at 12:56 PM, Yuri Kostin  wrote:

> Try adding IPs and host names to your /etc/hosts on all servers so all
> servers can find one another by hostname.
>
> On Sep 15, 2014, at 2:22 AM, Ayush Vatsyayan  wrote:
>
> Hi,
>
> I'm trying to run a multicluster storm setup. I've three machines, of
> which 1st one executes zookeeper, nimbus, and storm ui, while on 2nd and
> 3rd I'm running two supervisors.
>
> When I look at the supervisor logs, I'm getting following error
> *b.s.m.n.StromClientErrorHandler [Info] Connection failed
> Netty-Client-:6700*
> *java.nio.channels.UnresolvedAddressException: null*
> *at sun.nio.ch.Net.checkAddress(Net.java:85) ~[na:1.7.0_17]*
> *at
> sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:597)
> ~[na:1.7.0_17]*
> *at
> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:106)
> ~[ne$*
> *at
> org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:69)
> ~[n$*
> *at
> org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54)
> ~[netty-3.6.3.Fina$*
> *at org.jboss.netty.channel.Channels.connect(Channels.java:634)
> [netty-3.6.3.Final.jar:na]*
> *at
> org.jboss.netty.channel.AbstractChannel.connect(AbstractChannel.java:207)
> [netty-3.6.3.Final.jar:na]*
> *at
> org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:229)
> [netty-3.6.3.Final.jar:na]*
> *at
> org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:182)
> [netty-3.6.3.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-incubatin$*
> *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_17]*
> *at
> java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
> [na:1.7.0_17]*
> *at java.util.concurrent.FutureTask.run(FutureTask.java:166)
> [na:1.7.0_17]*
> *at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:$*
> *at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292)
> [n$*
> *at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> [na:1.7.0_17]*
> *at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> [na:1.7.0_17]*
> *at java.lang.Thread.run(Thread.java:722) [na:1.7.0_17]*
>
> I tried to telnet on the machine (telnet 
> 6700) with ipaddress it works fine, but not with the hostname of the other
> supervisor (telnet says unknown host).
>
> Any help is really appreciable.
>
> Many thanks,
> Ayush V.
>
>
>