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.