the storm version is Storm 1.0.2. 2017-04-27 11:56 GMT+08:00 Dmitry Semenov <[email protected]>:
> Looks like very old version of storm, which one are you using? > > > On Apr 26, 2017 at 7:37 PM, <马庆祥 <[email protected]>> wrote: > > Hello all. > > I found a strange error in log file which can cause worker restart. it > seems to be thrown by storm itself rather my program. > > > > The error message is: > > 2017-04-26 19:14:34.721 o.a.s.m.n.StormServerHandler [ERROR] server errors in > handling the request > java.io.IOException: Connection reset by peer > at sun.nio.ch.FileDispatcherImpl.read0(Native Method) ~[?:1.7.0_40] > at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39) > ~[?:1.7.0_40] > at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223) > ~[?:1.7.0_40] > at sun.nio.ch.IOUtil.read(IOUtil.java:192) ~[?:1.7.0_40] > at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:379) > ~[?:1.7.0_40] > at > org.apache.storm.shade.org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:64) > [storm-core-1.0.2.jar:1.0.2] > at > org.apache.storm.shade.org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108) > [storm-core-1.0.2.jar:1.0.2] > at > org.apache.storm.shade.org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:318) > [storm-core-1.0.2.jar:1.0.2] > at > org.apache.storm.shade.org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89) > [storm-core-1.0.2.jar:1.0.2] > at > org.apache.storm.shade.org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178) > [storm-core-1.0.2.jar:1.0.2] > at > org.apache.storm.shade.org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108) > [storm-core-1.0.2.jar:1.0.2] > at > org.apache.storm.shade.org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42) > [storm-core-1.0.2.jar:1.0.2] > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) > [?:1.7.0_40] > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) > [?:1.7.0_40] > at java.lang.Thread.run(Thread.java:724) [?:1.7.0_40] > > > > > And there are mang log as shown below: > 2017-04-26 19:17:19.516 o.a.s.m.n.Client [INFO] closing Netty Client > Netty-Client-/X.X.X.X:6720 > 2017-04-26 19:17:19.518 o.a.s.m.n.Client [INFO] waiting up to 600000 ms to > send 0 pending messages to Netty-Client-/X.X.X.X:6720 > 2017-04-26 19:17:19.520 o.a.s.m.n.Client [INFO] closing Netty Client > Netty-Client-/X.X.X.X:6723 > 2017-04-26 19:17:19.520 o.a.s.m.n.Client [INFO] waiting up to 600000 ms to > send 0 pending messages to Netty-Client-/X.X.X.X:6723 > 2017-04-26 19:17:19.521 o.a.s.m.n.Client [INFO] closing Netty Client > Netty-Client-/X.X.X.X:6720 > 2017-04-26 19:17:19.522 o.a.s.m.n.Client [INFO] waiting up to 600000 ms to > send 0 pending messages to Netty-Client-/X.X.X.X:6720 > ... ... > > > Thanks & Regards > Qingxiang Ma > >
