[FLINK-3019] [client] List restarting jobs with scheduled jobs

nltran · Nov 19, 2015 · 9abbeac · 9abbeac
1 parent 5a86a0a
commit 9abbeac
Showing 1 changed file with 4 additions and 3 deletions.
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
@@ -509,7 +509,8 @@ protected int list(String[] args) {
  }
 
  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)) {
@@ -532,10 +533,10 @@ public int compare(JobStatusMessage o1, JobStatusMessage o2) {
  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("--------------------------------------------------------------");
  }