[
https://issues.apache.org/jira/browse/FLINK-1892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14574167#comment-14574167
]
Stephan Ewen commented on FLINK-1892:
-------------------------------------
Let's bump the Tez version to 0.6.1 to get the fix in.
> Local job execution does not exit.
> ----------------------------------
>
> Key: FLINK-1892
> URL: https://issues.apache.org/jira/browse/FLINK-1892
> Project: Flink
> Issue Type: Bug
> Components: Flink on Tez
> Reporter: Kostas Tzoumas
> Assignee: Kostas Tzoumas
>
> When using the LocalTezEnvironment to run a job from the IDE the job fails to
> exit after producing data. The following thread seems to run and not allow
> the job to exit:
> "Thread-31" #46 prio=5 os_prio=31 tid=0x00007fb5d2c43000 nid=0x5507 runnable
> [0x0000000127319000]
> java.lang.Thread.State: RUNNABLE
> at java.lang.Throwable.fillInStackTrace(Native Method)
> at java.lang.Throwable.fillInStackTrace(Throwable.java:783)
> - locked <0x000000076dfda130> (a java.lang.InterruptedException)
> at java.lang.Throwable.<init>(Throwable.java:250)
> at java.lang.Exception.<init>(Exception.java:54)
> at java.lang.InterruptedException.<init>(InterruptedException.java:57)
> at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly(AbstractQueuedSynchronizer.java:1220)
> at
> java.util.concurrent.locks.ReentrantLock.lockInterruptibly(ReentrantLock.java:335)
> at
> java.util.concurrent.PriorityBlockingQueue.take(PriorityBlockingQueue.java:545)
> at
> org.apache.tez.dag.app.rm.LocalTaskSchedulerService$AsyncDelegateRequestHandler.processRequest(LocalTaskSchedulerService.java:322)
> at
> org.apache.tez.dag.app.rm.LocalTaskSchedulerService$AsyncDelegateRequestHandler.run(LocalTaskSchedulerService.java:316)
> at java.lang.Thread.run(Thread.java:745)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
