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.

Reply via email to