[jira] [Created] (FLINK-1436) Command-line interface verbose option (-v)

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-1436) Command-line interface verbose option (-v)

Shang Yuanchun (Jira)
Max Michels created FLINK-1436:
----------------------------------

             Summary: Command-line interface verbose option (-v)
                 Key: FLINK-1436
                 URL: https://issues.apache.org/jira/browse/FLINK-1436
             Project: Flink
          Issue Type: Improvement
          Components: Start-Stop Scripts
            Reporter: Max Michels
            Priority: Trivial


Let me run just a basic Flink job and add the verbose flag. It's a general option, so let me add it as a first parameter:

> ./flink -v run ../examples/flink-java-examples-0.8.0-WordCount.jar hdfs:///input hdfs:///output9
Invalid action!
./flink <ACTION> [GENERAL_OPTIONS] [ARGUMENTS]
  general options:
     -h,--help      Show the help for the CLI Frontend.
     -v,--verbose   Print more detailed error messages.

Action "run" compiles and runs a program.

  Syntax: run [OPTIONS] <jar-file> <arguments>
  "run" action arguments:
     -c,--class <classname>           Class with the program entry point ("main"
                                      method or "getPlan()" method. Only needed
                                      if the JAR file does not specify the class
                                      in its manifest.
     -m,--jobmanager <host:port>      Address of the JobManager (master) to
                                      which to connect. Use this flag to connect
                                      to a different JobManager than the one
                                      specified in the configuration.
     -p,--parallelism <parallelism>   The parallelism with which to run the
                                      program. Optional flag to override the
                                      default value specified in the
                                      configuration.

Action "info" displays information about a program.
  "info" action arguments:
     -c,--class <classname>           Class with the program entry point ("main"
                                      method or "getPlan()" method. Only needed
                                      if the JAR file does not specify the class
                                      in its manifest.
     -e,--executionplan               Show optimized execution plan of the
                                      program (JSON)
     -m,--jobmanager <host:port>      Address of the JobManager (master) to
                                      which to connect. Use this flag to connect
                                      to a different JobManager than the one
                                      specified in the configuration.
     -p,--parallelism <parallelism>   The parallelism with which to run the
                                      program. Optional flag to override the
                                      default value specified in the
                                      configuration.

Action "list" lists running and finished programs.
  "list" action arguments:
     -m,--jobmanager <host:port>   Address of the JobManager (master) to which
                                   to connect. Use this flag to connect to a
                                   different JobManager than the one specified
                                   in the configuration.
     -r,--running                  Show running programs and their JobIDs
     -s,--scheduled                Show scheduled prorgrams and their JobIDs

Action "cancel" cancels a running program.
  "cancel" action arguments:
     -i,--jobid <jobID>            JobID of program to cancel
     -m,--jobmanager <host:port>   Address of the JobManager (master) to which
                                   to connect. Use this flag to connect to a
                                   different JobManager than the one specified
                                   in the configuration.

What just happened? This results in a lot of output which is usually generated if you use the --help option on command-line tools. If your terminal window is large enough, then you will see a tiny message:

"Please specify an action". I did specify an action. Strange. If you read the help messages carefully you see, that "general options" belong to the action.

> ./flink run -v ../examples/flink-java-examples-0.8.0-WordCount.jar hdfs:///input hdfs:///output9

For the sake of mitigating user frustration, let us also accept -v as the first argument. It may seem trivial for the day-to-day Flink user but makes a difference for a novice.




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)