Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6049#discussion_r189803747
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java ---
@@ -394,29 +394,33 @@ protected void list(String[] args) throws Exception {
final boolean running;
final boolean scheduled;
+ final boolean other;
// print running and scheduled jobs if not option supplied
- if (!listOptions.getRunning() && !listOptions.getScheduled()) {
+ if (!listOptions.getRunning() && !listOptions.getScheduled() &&
!listOptions.getOther()) {
running = true;
scheduled = true;
+ other = false;
} else {
running = listOptions.getRunning();
scheduled = listOptions.getScheduled();
+ other = listOptions.getOther();
}
final CustomCommandLine<?> activeCommandLine =
getActiveCustomCommandLine(commandLine);
runClusterAction(
activeCommandLine,
commandLine,
- clusterClient -> listJobs(clusterClient, running,
scheduled));
+ clusterClient -> listJobs(clusterClient, running,
scheduled, other));
}
private <T> void listJobs(
ClusterClient<T> clusterClient,
boolean running,
- boolean scheduled) throws FlinkException {
+ boolean scheduled,
+ boolean other) throws FlinkException {
--- End diff --
rename to `showRemaining`
---
