Thanks for the reply, my application connects to a kinesis stream and processes data using storm and throws the processed data to a service, and it is working fine before. So the issue is with supervisors? or with the server to which i am throwing the processed data or any other issue. could you explain it.
ThankYou, G V Chandrahas Raj On Wed, Dec 10, 2014 at 10:00 PM, Bobby Evans <[email protected]> wrote: > This looks like one of your clients is shutting down a connection early, > or crashing mid connection. I would look at the clients to see what they > are doing. > > - Bobby > > > On Wednesday, December 10, 2014 10:28 AM, Chandrahas Gurram < > [email protected]> wrote: > > > Hi > I am working on storm-0.9.2 and have tested the project before too, but > suddenly nimbus started throwing following error. can anyone help me with > this problem. > > 2014-12-10 16:18:55 o.a.t.s.TNonblockingServer [WARN] Got an IOException > in internalRead! > java.io.IOException: Connection reset by peer > at sun.nio.ch.FileDispatcherImpl.read0(Native Method) > ~[na:1.7.0_65] > at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39) > ~[na:1.7.0_65] > at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223) > ~[na:1.7.0_65] > at sun.nio.ch.IOUtil.read(IOUtil.java:197) ~[na:1.7.0_65] > at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:379) > ~[na:1.7.0_65] > at > org.apache.thrift7.transport.TNonblockingSocket.read(TNonblockingSocket.java:141) > ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] > at > org.apache.thrift7.server.TNonblockingServer$FrameBuffer.internalRead(TNonblockingServer.java:669) > [storm-core-0.9.2-incubating.jar:0.9.2-incubating] > at > org.apache.thrift7.server.TNonblockingServer$FrameBuffer.read(TNonblockingServer.java:458) > [storm-core-0.9.2-incubating.jar:0.9.2-incubating] > at > org.apache.thrift7.server.TNonblockingServer$SelectThread.handleRead(TNonblockingServer.java:359) > [storm-core-0.9.2-incubating.jar:0.9.2-incubating] > at > org.apache.thrift7.server.TNonblockingServer$SelectThread.select(TNonblockingServer.java:304) > [storm-core-0.9.2-incubating.jar:0.9.2-incubating] > at > org.apache.thrift7.server.TNonblockingServer$SelectThread.run(TNonblockingServer.java:243) > [storm-core-0.9.2-incubating.jar:0.9.2-incubating] > > > ThankYou, > G V Chandrahas Raj > > >
