You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/01/12 22:25:29 UTC
[08/14] flink git commit: [hotfix] Add help command to
FlinkYarnSessionCli
[hotfix] Add help command to FlinkYarnSessionCli
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2ce64e79
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2ce64e79
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2ce64e79
Branch: refs/heads/master
Commit: 2ce64e791b3a2e2b8a8e4ac774f2ca45da5660dc
Parents: 402499f
Author: Till Rohrmann <tr...@apache.org>
Authored: Fri Dec 29 15:12:46 2017 +0100
Committer: Till Rohrmann <tr...@apache.org>
Committed: Fri Jan 12 16:14:04 2018 +0100
----------------------------------------------------------------------
.../java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java | 8 ++++++++
1 file changed, 8 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/2ce64e79/flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java
----------------------------------------------------------------------
diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java b/flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java
index 75a270d..24a422e 100644
--- a/flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java
+++ b/flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java
@@ -127,6 +127,7 @@ public class FlinkYarnSessionCli extends AbstractCustomCommandLine {
private final Option detached;
private final Option zookeeperNamespace;
private final Option flip6;
+ private final Option help;
/**
* @deprecated Streaming mode has been deprecated without replacement. Set the
@@ -198,6 +199,7 @@ public class FlinkYarnSessionCli extends AbstractCustomCommandLine {
name = new Option(shortPrefix + "nm", longPrefix + "name", true, "Set a custom name for the application on YARN");
zookeeperNamespace = new Option(shortPrefix + "z", longPrefix + "zookeeperNamespace", true, "Namespace to create the Zookeeper sub-paths for high availability mode");
flip6 = new Option(shortPrefix + "f6", longPrefix + "flip6", false, "Specify this option to start a Flip-6 Yarn session cluster.");
+ help = new Option(shortPrefix + "h", longPrefix + "help", false, "Help for the Yarn session CLI.");
allOptions = new Options();
allOptions.addOption(flinkJar);
@@ -215,6 +217,7 @@ public class FlinkYarnSessionCli extends AbstractCustomCommandLine {
allOptions.addOption(applicationId);
allOptions.addOption(zookeeperNamespace);
allOptions.addOption(flip6);
+ allOptions.addOption(help);
// try loading a potential yarn properties file
this.yarnPropertiesFileLocation = configuration.getString(YarnConfigOptions.PROPERTIES_FILE_LOCATION);
@@ -564,6 +567,11 @@ public class FlinkYarnSessionCli extends AbstractCustomCommandLine {
//
final CommandLine cmd = parseCommandLineOptions(args, true);
+ if (cmd.hasOption(help.getOpt())) {
+ printUsage();
+ return 0;
+ }
+
final AbstractYarnClusterDescriptor yarnClusterDescriptor = createClusterDescriptor(cmd);
try {