Thanks Nick. I seem to have two installations in the box. Removing them seemed to give a respite. However, now the nodes dont talk to each other at all. No emits and spout does not accept any messages. :(
Thanks kashyap On Thu, Sep 24, 2015 at 7:48 AM, Nick R. Katsipoulakis < [email protected]> wrote: > Hello Kashyap, > > I have come up with something similar before. However, I have not yet > figured out how I can avoid these kind of Exceptions. > > Nick > > On Thu, Sep 24, 2015 at 5:19 AM, Kashyap Mhaisekar <[email protected]> > wrote: > >> Hi, >> To fix Netty reconnect issues, I upgraded to 0.9.5 of storm and it worked >> well in one environment. While in stress environment, i noticed the below. >> My Dev env has 5 boxes as a cluster while stress env has 8 boxes. Has >> anyone come across this before? >> ----------------------------- >> 2015-09-24T04:12:32.034-0500 b.s.m.n.StormClientErrorHandler [INFO] >> Connection failed Netty-Client-myserver1.myorg.com/10.2.72.70:6702 >> java.io.IOException: Connection reset by peer >> at sun.nio.ch.FileDispatcherImpl.read0(Native Method) >> ~[na:1.7.0_79] >> at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39) >> ~[na:1.7.0_79] >> at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223) >> ~[na:1.7.0_79] >> at sun.nio.ch.IOUtil.read(IOUtil.java:192) ~[na:1.7.0_79] >> at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:379) >> ~[na:1.7.0_79] >> at >> org.apache.storm.netty.channel.socket.nio.NioWorker.read(NioWorker.java:64) >> [storm-core-0.9.5.jar:0.9.5] >> at >> org.apache.storm.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108) >> [storm-core-0.9.5.jar:0.9.5] >> at >> org.apache.storm.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:318) >> [storm-core-0.9.5.jar:0.9.5] >> at >> org.apache.storm.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89) >> [storm-core-0.9.5.jar:0.9.5] >> at >> org.apache.storm.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178) >> [storm-core-0.9.5.jar:0.9.5] >> at >> org.apache.storm.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108) >> [storm-core-0.9.5.jar:0.9.5] >> at >> org.apache.storm.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42) >> [storm-core-0.9.5.jar:0.9.5] >> at >> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) >> [na:1.7.0_79] >> at >> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) >> [na:1.7.0_79] >> at java.lang.Thread.run(Thread.java:745) [na:1.7.0_79] >> ------------------------------------------------- >> >> Thanks >> Kashyap >> > > > > -- > Nikolaos Romanos Katsipoulakis, > University of Pittsburgh, PhD student >
