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:54:39 UTC
[07/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/2b693502
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2b693502
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2b693502
Branch: refs/heads/release-1.5
Commit: 2b693502318dd3bfdae352b6ae4f4be6e4443bbc
Parents: 4079114
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:53:50 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/2b693502/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);
}
/**