storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "/pig五餐肉" <76006...@qq.com>
Subject Drpc Server Got an Io Exception
Date Wed, 16 Jul 2014 02:24:41 GMT
Hi All


I am running a drpc topology for data filtering. I can get the result when i run DrpcClient
execute method.
However ,when i check the drpc.log on drpc server. I find some exceptions below:


 o.a.t.s.TNonblockingServer [WARN] Got an IOException during write!
java.io.IOException: Connection reset by peer
        at sun.nio.ch.FileDispatcherImpl.write0(Native Method) ~[na:1.7.0_60]
        at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:47) ~[na:1.7.0_60]
        at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:93) ~[na:1.7.0_60]
        at sun.nio.ch.IOUtil.write(IOUtil.java:65) ~[na:1.7.0_60]
        at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:487) ~[na:1.7.0_60]
        at org.apache.thrift7.transport.TNonblockingSocket.write(TNonblockingSocket.java:164)
~[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
        at org.apache.thrift7.server.TNonblockingServer$FrameBuffer.write(TNonblockingServer.java:533)
~[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
        at org.apache.thrift7.server.TNonblockingServer$SelectThread.handleWrite(TNonblockingServer.java:377)
[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
        at org.apache.thrift7.server.TNonblockingServer$SelectThread.select(TNonblockingServer.java:307)
[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
        at org.apache.thrift7.server.TNonblockingServer$SelectThread.run(TNonblockingServer.java:243)
[storm-core-0.9.1-incubating.jar:0.9.1-incubating]‍



 how to address this issue? Thanks.
Mime
View raw message