You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@storm.apache.org by "Rick Kellogg (JIRA)" <ji...@apache.org> on 2015/10/09 03:36:27 UTC
[jira] [Updated] (STORM-192) NETTY DRPC cluster: When the number of
worker if higher than 1 with more than one supervisor, the topology fail to
execute
[ https://issues.apache.org/jira/browse/STORM-192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Rick Kellogg updated STORM-192:
-------------------------------
Component/s: storm-core
> 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
> Issue Type: Bug
> Components: storm-core
> 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.3.4#6332)