[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 <[email protected]> Authored: Thu Feb 22 18:24:17 2018 +0100 Committer: Till Rohrmann <[email protected]> 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();
