[
https://issues.apache.org/jira/browse/TAJO-1279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinho Kim updated TAJO-1279:
----------------------------
Description:
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}
was:
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.
> 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
>
> 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)
