You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2017/03/30 22:04:54 UTC
[43/50] [abbrv] flink git commit: [hotfix] [dist. coordination] Fix
waiting for execution termination
[hotfix] [dist. coordination] Fix waiting for execution termination
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/85f75a59
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/85f75a59
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/85f75a59
Branch: refs/heads/table-retraction
Commit: 85f75a5999cfeabb82f24f1f3c4cd998a4c5b348
Parents: 60895a3
Author: Stephan Ewen <se...@apache.org>
Authored: Fri Mar 24 10:45:07 2017 +0100
Committer: Stephan Ewen <se...@apache.org>
Committed: Wed Mar 29 17:11:49 2017 +0200
----------------------------------------------------------------------
.../org/apache/flink/runtime/executiongraph/ExecutionGraph.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/85f75a59/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
index 1c7b1c8..0564fd0 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
@@ -1090,11 +1090,10 @@ public class ExecutionGraph implements AccessExecutionGraph, Archiveable<Archive
/**
* For testing: This waits until the job execution has finished.
- * @throws InterruptedException
*/
public void waitUntilFinished() throws InterruptedException {
synchronized (progressLock) {
- while (!state.isGloballyTerminalState()) {
+ while (!state.isTerminalState()) {
progressLock.wait();
}
}