[
https://issues.apache.org/jira/browse/TAJO-1279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14268940#comment-14268940
]
Hudson commented on TAJO-1279:
------------------------------
SUCCESS: Integrated in Tajo-master-build #539 (See
[https://builds.apache.org/job/Tajo-master-build/539/])
TAJO-1279: Cleanup TajoAsyncDispatcher and interrupt stop events. (jinho)
(jhkim: rev 6582d8656a3e8147984a86a9e62688b52ec1f681)
* tajo-core/src/test/java/org/apache/tajo/cli/tsql/TestTajoCli.java
* tajo-core/src/main/java/org/apache/tajo/master/TajoAsyncDispatcher.java
* tajo-core/src/main/java/org/apache/tajo/master/event/QueryStopEvent.java
* tajo-core/src/test/java/org/apache/tajo/scheduler/TestFifoScheduler.java
* tajo-core/src/main/java/org/apache/tajo/master/querymaster/Stage.java
* tajo-core/src/test/java/org/apache/tajo/worker/TestHistory.java
* tajo-core/src/test/java/org/apache/tajo/jdbc/TestTajoJdbc.java
* tajo-core/src/test/java/org/apache/tajo/TajoTestingCluster.java
* tajo-core/src/test/java/org/apache/tajo/master/querymaster/TestKillQuery.java
* tajo-core/src/main/java/org/apache/tajo/master/DefaultTaskScheduler.java
*
tajo-core/src/main/java/org/apache/tajo/master/querymaster/QueryInProgress.java
* tajo-core/src/main/java/org/apache/tajo/master/querymaster/QueryJobEvent.java
*
tajo-core/src/main/java/org/apache/tajo/master/querymaster/QueryMasterTask.java
* tajo-core/src/test/java/org/apache/tajo/TpchTestBase.java
* tajo-core/src/main/java/org/apache/tajo/benchmark/TPCH.java
*
tajo-core/src/main/java/org/apache/tajo/master/querymaster/QueryJobManager.java
* CHANGES
* tajo-core/src/main/java/org/apache/tajo/master/querymaster/QueryMaster.java
* tajo-core/src/test/java/org/apache/tajo/QueryTestCaseBase.java
> Cleanup TajoAsyncDispatcher and interrupt stop events
> -----------------------------------------------------
>
> Key: TAJO-1279
> URL: https://issues.apache.org/jira/browse/TAJO-1279
> Project: Tajo
> Issue Type: Improvement
> Components: query master
> Affects Versions: 0.8.0, 0.9.0
> Reporter: Jinho Kim
> Assignee: Jinho Kim
> Priority: Minor
> Fix For: 0.10
>
> Attachments: TAJO-1279.patch
>
>
> See the titile.
> {{TajoAsyncDispatcher}} is an implementation copied from yarn
> {{AsyncDispatcher}} for log message handling. but too many create the thread
> interrupted message.
> We should improve the stop event.
> {noformat}
> 2014-12-17 10:08:35,327 WARN: org.apache.tajo.master.TajoAsyncDispatcher
> (stop(115)) - Interrupted Exception while stopping
> 2014-12-17 10:08:35,328 WARN: org.apache.tajo.master.TajoAsyncDispatcher
> (stop(115)) - Interrupted Exception while stopping
> 2014-12-17 10:08:36,896 WARN: org.apache.tajo.master.TajoAsyncDispatcher
> (stop(115)) - Interrupted Exception while stopping
> 2014-12-17 10:08:36,898 WARN: org.apache.tajo.master.TajoAsyncDispatcher
> (stop(115)) - Interrupted Exception while stopping
> 2014-12-17 10:08:37,745 FATAL: org.apache.tajo.master.TajoAsyncDispatcher
> (dispatch(143)) - Error in dispatcher thread:QUERY_JOB_HEARTBEAT
> org.apache.hadoop.yarn.exceptions.YarnRuntimeException:
> java.lang.InterruptedException
> at
> org.apache.tajo.master.TajoAsyncDispatcher$GenericEventHandler.handle(TajoAsyncDispatcher.java:204)
> at
> org.apache.tajo.master.querymaster.QueryInProgress.heartbeat(QueryInProgress.java:290)
> at
> org.apache.tajo.master.querymaster.QueryInProgress.access$000(QueryInProgress.java:53)
> at
> org.apache.tajo.master.querymaster.QueryInProgress$QueryInProgressEventHandler.handle(QueryInProgress.java:196)
> at
> org.apache.tajo.master.querymaster.QueryInProgress$QueryInProgressEventHandler.handle(QueryInProgress.java:192)
> at
> org.apache.tajo.master.TajoAsyncDispatcher.dispatch(TajoAsyncDispatcher.java:137)
> at
> org.apache.tajo.master.TajoAsyncDispatcher$1.run(TajoAsyncDispatcher.java:79)
> at java.lang.Thread.run(Thread.java:701)
> Caused by: java.lang.InterruptedException
> at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly(AbstractQueuedSynchronizer.java:1222)
> at
> java.util.concurrent.locks.ReentrantLock.lockInterruptibly(ReentrantLock.java:340)
> at
> java.util.concurrent.LinkedBlockingQueue.put(LinkedBlockingQueue.java:269)
> at
> org.apache.tajo.master.TajoAsyncDispatcher$GenericEventHandler.handle(TajoAsyncDispatcher.java:199)
> ... 7 more
> 2014-12-17 10:08:37,746 WARN: org.apache.tajo.master.TajoAsyncDispatcher
> (stop(115)) - Interrupted Exception while stopping
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
