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/02/24 18:17:44 UTC

[2/9] flink git commit: [hotfix] Register job status listener for rescaled job

[hotfix] Register job status listener for rescaled job


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c73f94e2
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c73f94e2
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c73f94e2

Branch: refs/heads/master
Commit: c73f94e21c0d6e5ebd9b91dfa6b6e20da528093a
Parents: 662ed3d
Author: Till Rohrmann <tr...@apache.org>
Authored: Thu Feb 22 18:24:17 2018 +0100
Committer: Till Rohrmann <tr...@apache.org>
Committed: Sat Feb 24 15:04:38 2018 +0100

----------------------------------------------------------------------
 .../main/java/org/apache/flink/runtime/jobmaster/JobMaster.java   | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/c73f94e2/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
index 4d982fd..f7841e2 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
@@ -639,6 +639,9 @@ public class JobMaster extends FencedRpcEndpoint<JobMasterId> implements JobMast
 				if (executionGraph == currentExecutionGraph) {
 					executionGraph = restoredExecutionGraph;
 
+					// register self as job status change listener
+					executionGraph.registerJobStatusListener(new JobManagerJobStatusListener());
+
 					scheduleExecutionGraph();
 
 					return Acknowledge.get();