You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/06/12 09:37:00 UTC
[2/5] flink git commit: [FLINK-9398][cli] Only list non-terminal jobs
in running section
[FLINK-9398][cli] Only list non-terminal jobs in running section
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a2a85bcb
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a2a85bcb
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a2a85bcb
Branch: refs/heads/master
Commit: a2a85bcb3cdb5202055984604f45809260787fd5
Parents: 42e90c7
Author: Rong Rong <wa...@hotmail.com>
Authored: Mon Jun 11 10:35:29 2018 +0200
Committer: zentol <ch...@apache.org>
Committed: Tue Jun 12 11:34:38 2018 +0200
----------------------------------------------------------------------
.../src/main/java/org/apache/flink/client/cli/CliFrontend.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/a2a85bcb/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java
----------------------------------------------------------------------
diff --git a/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java b/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java
index fd12a73..f01f5b8 100644
--- a/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java
+++ b/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java
@@ -439,7 +439,7 @@ public class CliFrontend {
jobDetails.forEach(details -> {
if (details.getJobState() == JobStatus.CREATED) {
scheduledJobs.add(details);
- } else {
+ } else if (!details.getJobState().isGloballyTerminalState()) {
runningJobs.add(details);
}
});