reef-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Markus Weimer <mar...@weimo.de>
Subject Re: Unexpected exception from downstream while disposing evaluator.
Date Mon, 17 Jul 2017 14:54:03 GMT
Where is this exception thrown? Driver or Evaluator?

Markus

On Sat, Jul 15, 2017 at 8:22 PM, Achuth Raghavendra
<acragh@microsoft.com.invalid> wrote:
> I see exceptions while disposing a evaluator when a Task is complete. is this expected
?.
>
> /// <summary>
>         /// Called when [next].
>         /// </summary>
>         /// <param name="value">The value.</param>
>         public void OnNext(ICompletedTask value)
>         {
> ....
>             value.ActiveContext.Dispose(); // this will dispose the evaluator.
>         }
>
>
> INFO: Unexpected exception from downstream. channel: [id: 0x6075988d, /100.96.37.97:56404
=> /100.96.14.37:2014] local: /100.96.14.37:2014 remote: /100.96.37.97:56404
> Jul 15, 2017 8:11:34 PM org.apache.reef.wake.remote.transport.netty.NettyChannelHandler
exceptionCaught
> WARNING: Unexpected exception from downstream.
> java.io.IOException: An existing connection was forcibly closed by the remote host
>                 at sun.nio.ch.SocketDispatcher.read0(Native Method)
>                 at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:43)
>                 at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
>                 at sun.nio.ch.IOUtil.read(IOUtil.java:192)
>                 at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:379)
>                 at io.netty.buffer.UnpooledUnsafeDirectByteBuf.setBytes(UnpooledUnsafeDirectByteBuf.java:446)
>                 at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:879)
>                 at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:225)
>                 at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:114)
>                 at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
>                 at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
>                 at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
>                 at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
>                 at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
>                 at java.lang.Thread.run(Thread.java:745)

Mime
View raw message