[
https://issues.apache.org/jira/browse/FLINK-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16483604#comment-16483604
]
ASF GitHub Bot commented on FLINK-9398:
---------------------------------------
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`
> Flink CLI list running job returns all jobs except in CREATE state
> ------------------------------------------------------------------
>
> Key: FLINK-9398
> URL: https://issues.apache.org/jira/browse/FLINK-9398
> Project: Flink
> Issue Type: Bug
> Components: Client
> Affects Versions: 1.5.0
> Reporter: Rong Rong
> Assignee: Rong Rong
> Priority: Major
>
> See:
> https://github.com/apache/flink/blob/4922ced71a307a26b9f5070b41f72fd5d93b0ac8/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java#L437-L445
> Seems like CLI command: *flink list -r* returns all jobs except jobs in
> *CREATE* state. which conflicts with the CLI description: *Running/Restarting
> Jobs*.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
