diff --git a/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java b/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java index 475d8544cfed8..402b4ae7f2fc0 100644 --- a/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java +++ b/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java @@ -350,16 +350,14 @@ private static void printCustomCliOptions( boolean runOptions) { // prints options from all available command-line classes for (CustomCommandLine cli: customCommandLines) { - if (cli.getId() != null) { - formatter.setSyntaxPrefix(" Options for " + cli.getId() + " mode:"); - Options customOpts = new Options(); - cli.addGeneralOptions(customOpts); - if (runOptions) { - cli.addRunOptions(customOpts); - } - formatter.printHelp(" ", customOpts); - System.out.println(); + formatter.setSyntaxPrefix(" Options for " + cli.getId() + " mode:"); + Options customOpts = new Options(); + cli.addGeneralOptions(customOpts); + if (runOptions) { + cli.addRunOptions(customOpts); } + formatter.printHelp(" ", customOpts); + System.out.println(); } } diff --git a/flink-clients/src/main/java/org/apache/flink/client/cli/DefaultCLI.java b/flink-clients/src/main/java/org/apache/flink/client/cli/DefaultCLI.java index d2694b88facc7..2ca5a65604bca 100644 --- a/flink-clients/src/main/java/org/apache/flink/client/cli/DefaultCLI.java +++ b/flink-clients/src/main/java/org/apache/flink/client/cli/DefaultCLI.java @@ -45,7 +45,7 @@ public boolean isActive(CommandLine commandLine) { @Override public String getId() { - return null; + return "Default CLI"; } @Override