Repository: flink Updated Branches: refs/heads/release-0.10 9defe0cb2 -> 7f3d08ffd
[FLINK-3019] [client] List restarting jobs with scheduled jobs Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/440ccc1a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/440ccc1a Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/440ccc1a Branch: refs/heads/release-0.10 Commit: 440ccc1aff446d419ca6c80b200d036fdd530e58 Parents: bf065a3 Author: Ufuk Celebi <u...@apache.org> Authored: Tue Nov 17 14:11:44 2015 +0100 Committer: Ufuk Celebi <u...@apache.org> Committed: Thu Nov 19 18:27:03 2015 +0100 ---------------------------------------------------------------------- .../src/main/java/org/apache/flink/client/CliFrontend.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/440ccc1a/flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---------------------------------------------------------------------- diff --git a/flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java b/flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java index 2211012..7c8d52e 100644 --- a/flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java +++ b/flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java @@ -519,7 +519,8 @@ public class CliFrontend { } for (JobStatusMessage rj : jobs) { - if (running && rj.getJobState().equals(JobStatus.RUNNING)) { + if (running && (rj.getJobState().equals(JobStatus.RUNNING) + || rj.getJobState().equals(JobStatus.RESTARTING))) { runningJobs.add(rj); } if (scheduled && rj.getJobState().equals(JobStatus.CREATED)) { @@ -542,10 +543,10 @@ public class CliFrontend { else { Collections.sort(runningJobs, njec); - System.out.println("------------------------ Running Jobs ------------------------"); + System.out.println("------------------ Running/Restarting Jobs -------------------"); for (JobStatusMessage rj : runningJobs) { System.out.println(df.format(new Date(rj.getStartTime())) - + " : " + rj.getJobId() + " : " + rj.getJobName()); + + " : " + rj.getJobId() + " : " + rj.getJobName() + " (" + rj.getJobState() + ")"); } System.out.println("--------------------------------------------------------------"); }
