philippe created STORM-192:
------------------------------
Summary: NETTY DRPC cluster: When the number of worker if higher
than 1 with more than one supervisor, the topology fail to execute
Key: STORM-192
URL: https://issues.apache.org/jira/browse/STORM-192
Project: Apache Storm (Incubating)
Issue Type: Bug
Environment: Windows 7
Reporter: philippe
On a cluster with one supervisor it work.
Even it have more than one worker.
But when I had more than one supervisor it don't work when I have more than one
worker.
I have port set for the worker and they are not used.
Worker log look like this:
2014-01-07 16:09:08 STDIO [ERROR]
boss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:69)
at
org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54)
at org.jboss.netty.channel.Channels.connect(Channels.java:634)
at
org.jboss.netty.channel.AbstractChannel.connect(AbstractChannel.java:207)
at
org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:229)
at
org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:182)
at backtype.storm.messaging.netty.Client.reconnect(Client.java:96)
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.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:124)
at
org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:69)
at
org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54)
at org.jboss.netty.channel.Channels.connect(Channels.java:634)
at
org.jboss.netty.channel.AbstractChannel.connect(AbstractChannel.java:207)
at
org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:229)
at
org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:182)
at backtype.storm.messaging.netty.Client.reconnect(Client.java:96)
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.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:124)
at
org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:69)
at
org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54)
at org.jboss.netty.channel.Channels.connect(Channels.java:634)
at
org.jboss.netty.channel.AbstractChannel.connect(AbstractChannel.java:207)
at
org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:229)
at
org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:182)
at backtype.storm.messaging.netty.Client.reconnect(Client.java:96)
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.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:124)
at
org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:69)
at
org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54)
at org.jboss.netty.channel.Channels.connect(Channels.java:634)
at
org.jboss.netty.channel.AbstractChannel.connect(AbstractChannel.java:207)
at
org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:229)
at
org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:182)
at backtype.storm.messaging.netty.Client.reconnect(Client.java:96)
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.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:124)
at
org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:69)
at
org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54)
at org.jboss.netty.channel.Channels.connect(Channels.java:634)
at
org.jboss.netty.channel.AbstractChannel.connect(AbstractChannel.java:207)
at
org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:229)
at
org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:182)
at backtype.storm.messaging.netty.Client.reconnect(Client.java:96)
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.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:124)
at
org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:69)
at
org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54)
at org.jboss.netty.channel.Channels.connect(Channels.java:634)
at
org.jboss.netty.channel.AbstractChannel.connect(AbstractChannel.java:207)
at
org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:229)
at
org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:182)
at backtype.storm.messaging.netty.Client.reconnect(Client.java:96)
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.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:124)
at
org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:69)
at
org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54)
at org.jboss.netty.channel.Channels.connect(Channels.java:634)
at
org.jboss.netty.channel.AbstractChannel.connect(AbstractChannel.java:207)
at
org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:229)
at
org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:182)
at backtype.storm.messaging.netty.Client.reconnect(Client.java:96)
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.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:124)
at
org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:69)
at
org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54)
at org.jboss.netty.channel.Channels.connect(Channels.java:634)
at
org.jboss.netty.channel.AbstractChannel.connect(AbstractChannel.java:207)
at
org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:229)
at
org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:182)
at backtype.storm.messaging.netty.Client.reconnect(Client.java:96)
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.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:124)
at
org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:69)
at
org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54)
at org.jboss.netty.channel.Channels.connect(Channels.java:634)
at
org.jboss.netty.channel.AbstractChannel.connect(AbstractChannel.java:207)
at org.jboss.netty.bootstrap.ClientBootstrap.conn
2014-01-07 16:09:08 STDIO [ERROR] ect(ClientBootstrap.java:229)
at
org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:182)
at backtype.storm.messaging.netty.Client.reconnect(Client.java:96)
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.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:124)
at
org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:69)
at
org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54)
at org.jboss.netty.channel.Channels.connect(Channels.java:634)
at
org.jboss.netty.channel.AbstractChannel.connect(AbstractChannel.java:207)
at
org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:229)
at
org.jboss.netty.bootstrap.ClientBootstrap.connect(ClientBootstrap.java:182)
at backtype.storm.messaging.netty.Client.<init>(Client.java:84)
at backtype.storm.messaging.netty.Context.connect(Context.java:53)
at
backtype.storm.daemon.worker$mk_refresh_connections$this__5822$iter__5829__5833$fn__5834.invoke(worker.clj:265)
at clojure.lang.LazySeq.sval(LazySeq.java:42)
at clojure.lang.LazySeq.seq(LazySeq.java:60)
at clojure.lang.Cons.next(Cons.java:39)
at clojure.lang.RT.next(RT.java:587)
at clojure.core$next.invoke(core.clj:64)
at clojure.core$dorun.invoke(core.clj:2726)
at clojure.core$doall.invoke(core.clj:2741)
at
backtype.storm.daemon.worker$mk_refresh_connections$this__5822.invoke(worker.clj:259)
at
backtype.storm.daemon.worker$fn__5877$exec_fn__1242__auto____5878.invoke(worker.clj:372)
at clojure.lang.AFn.applyToHelper(AFn.java:185)
at clojure.lang.AFn.applyTo(AFn.java:151)
at clojure.core$apply.invoke(core.clj:601)
at
backtype.storm.daemon.worker$fn__5877$mk_worker__5933.doInvoke(worker.clj:344)
at clojure.lang.RestFn.invoke(RestFn.java:512)
at backtype.storm.daemon.worker$_main.invoke(worker.clj:454)
at clojure.lang.AFn.applyToHelper(AFn.java:172)
at clojure.lang.AFn.applyTo(AFn.java:151)
at backtype.storm.daemon.worker.main(Unknown Source)
--
This message was sent by Atlassian JIRA
(v6.1.5#6160)
