[
https://issues.apache.org/jira/browse/TAJO-1279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14267650#comment-14267650
]
ASF GitHub Bot commented on TAJO-1279:
--------------------------------------
Github user jinossy commented on the pull request:
https://github.com/apache/tajo/pull/331#issuecomment-69024228
@jihoonson
Thank you for the review!
Your log looks like security information. Could you show the error log to
me ?
In my log, the connection was established successfully
```
2015-01-07 22:31:46,996 INFO: org.apache.zookeeper.ZooKeeper (<init>(438))
- Initiating client connection, connectString=kimjh.localhost:61503
sessionTimeout=90000 watcher=catalogtracker-on-hconnection-0x3dbc3890,
quorum=kimjh.localhost:61503, baseZNode=/hbase
2015-01-07 22:31:46,998 INFO: org.apache.zookeeper.ClientCnxn
(logStartConnect(975)) - Opening socket connection to server
kimjh.localhost/192.168.101.41:61503. Will not attempt to authenticate using
SASL (unknown error)
2015-01-07 22:31:46,998 INFO: org.apache.zookeeper.ClientCnxn
(primeConnection(852)) - Socket connection established to
kimjh.localhost/192.168.101.41:61503, initiating session
2015-01-07 22:31:46,998 INFO:
org.apache.zookeeper.server.NIOServerCnxnFactory (run(197)) - Accepted socket
connection from /192.168.101.41:65438
```
> 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
> 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)
