[
https://issues.apache.org/jira/browse/TAJO-908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14058751#comment-14058751
]
Hudson commented on TAJO-908:
-----------------------------
SUCCESS: Integrated in Tajo-master-build #292 (See
[https://builds.apache.org/job/Tajo-master-build/292/])
TAJO-908: Fetcher does not retry, when pull server connection was closed.
(jinho) (jinossy: rev 01857dadd42bd55894ce6edb55159e80c30f6c30)
* tajo-common/src/main/proto/tajo_protos.proto
* CHANGES
* tajo-core/src/main/java/org/apache/tajo/worker/Task.java
* tajo-core/src/main/java/org/apache/tajo/worker/Fetcher.java
* tajo-core/src/test/java/org/apache/tajo/worker/TestFetcher.java
* tajo-common/src/main/java/org/apache/tajo/conf/TajoConf.java
*
tajo-yarn-pullserver/src/main/java/org/apache/tajo/pullserver/TajoPullServerService.java
> Fetcher does not retry, when pull server connection was closed
> --------------------------------------------------------------
>
> Key: TAJO-908
> URL: https://issues.apache.org/jira/browse/TAJO-908
> Project: Tajo
> Issue Type: Bug
> Components: data shuffle
> Affects Versions: 0.8.0, 0.9.0
> Reporter: Jinho Kim
> Assignee: Jinho Kim
> Fix For: 0.9.0
>
>
> Exception message as follows:
> {code:title=PullServer}
> 2014-07-04 09:45:21,150 ERROR pullserver.TajoPullServerService
> (TajoPullServerService.java:exceptionCaught(533)) - PullServer error:
> java.io.IOException: Connection timed out
> at sun.nio.ch.FileDispatcherImpl.read0(Native Method)
> at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
> 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
> org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:64)
> at
> org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:109)
> at
> org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:312)
> at
> org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:90)
> at
> org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> at java.lang.Thread.run(Thread.java:745)
> {code}
> {code:title=Fetcher}
> org.jboss.netty.channel.SimpleChannelUpstreamHandler
> WARN: EXCEPTION, please implement
> org.apache.tajo.worker.Fetcher$HttpClientHandler.exceptionCaught() for proper
> handling.
> java.io.IOException: Connection reset by peer
> at sun.nio.ch.FileDispatcherImpl.read0(Native Method)
> at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
> 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
> org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:64)
> at
> org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:109)
> at
> org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:312)
> at
> org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:90)
> at
> org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> at java.lang.Thread.run(Thread.java:745)
> 2014-07-04 10:56:44,561 INFO worker.Task (Task.java:waitForFetch(375)) -
> ta_1404438787481_0001_000004_000029_00 All fetches are done!
> {code}
--
This message was sent by Atlassian JIRA
(v6.2#6252)
