storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ​Chandrahas Gurram <chandraha...@peel.com>
Subject Re: nimbus not starting and supervisor crashing
Date Thu, 11 Dec 2014 05:36:29 GMT
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 <evans@yahoo-inc.com> 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 <
> chandrahas.g@peel.com> 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
>
>
>

Mime
View raw message