flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Kostas Tzoumas (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-1892) Local job execution does not exit.
Date Thu, 16 Apr 2015 10:04:59 GMT
Kostas Tzoumas created FLINK-1892:
-------------------------------------

             Summary: 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)

Mime
View raw message