[
https://issues.apache.org/jira/browse/STORM-192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
philippe closed STORM-192.
--------------------------
Resolution: Not A Problem
The problem was related to IPV6, in the storm.yaml i now use the the name of
the machine and not the ip address it have fix some error in the log.
The other problem in the storm.yaml I declare the DRCP server but in the java
code I was adding it as well but with less server so the yaml was overwrited
when deploy the topology.
> 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)
