Drpc Server Got an Io Exception

[/pig五餐肉 <76...@qq.com>]

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.