[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/master Commit: 85f75a5999cfeabb82f24f1f3c4cd998a4c5b348 Parents: 60895a3 Author: Stephan Ewen <[email protected]> Authored: Fri Mar 24 10:45:07 2017 +0100 Committer: Stephan Ewen <[email protected]> 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(); } }
