You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/03/02 07:53:06 UTC
[06/12] flink git commit: [hotfix] Unregister job from
JobManagerRunner before completing the result future
[hotfix] Unregister job from JobManagerRunner before completing the result future
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a108a41e
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a108a41e
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a108a41e
Branch: refs/heads/master
Commit: a108a41ed2040d2466d073b4bc44bd3b484dd20c
Parents: b25d300
Author: Till Rohrmann <tr...@apache.org>
Authored: Thu Mar 1 17:06:27 2018 +0100
Committer: Till Rohrmann <tr...@apache.org>
Committed: Fri Mar 2 08:52:33 2018 +0100
----------------------------------------------------------------------
.../java/org/apache/flink/runtime/jobmaster/JobManagerRunner.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/a108a41e/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerRunner.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerRunner.java b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerRunner.java
index 80aa673..8b64f0d 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerRunner.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerRunner.java
@@ -265,8 +265,8 @@ public class JobManagerRunner implements LeaderContender, OnCompletionActions, F
@Override
public void jobReachedGloballyTerminalState(ArchivedExecutionGraph executionGraph) {
// complete the result future with the terminal execution graph
- resultFuture.complete(executionGraph);
unregisterJobFromHighAvailability();
+ resultFuture.complete(executionGraph);
}
/**