之前下载的Flink 1.8,运行bin/flink run --help,会有 yarn-cluster 的一些参数,如下:
Options for yarn-cluster mode:
     -d,--detached                        If present, runs the job in
detached
                                          mode
     -m,--jobmanager <arg>                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.
     -sae,--shutdownOnAttachedExit        If the job is submitted in
attached
                                          mode, perform a best-effort
cluster
                                          shutdown when the CLI is
terminated
                                          abruptly, e.g., in response to a
user
                                          interrupt, such as typing Ctrl +
C.
     -yD <property=value>                 use value for given property
     -yd,--yarndetached                   If present, runs the job in
detached
                                          mode (deprecated; use non-YARN
                                          specific option instead)
     -yh,--yarnhelp                       Help for the Yarn session CLI.
     -yid,--yarnapplicationId <arg>       Attach to running YARN session
     -yj,--yarnjar <arg>                  Path to Flink jar file
     -yjm,--yarnjobManagerMemory <arg>    Memory for JobManager Container
with
                                          optional unit (default: MB)
     -yn,--yarncontainer <arg>            Number of YARN container to
allocate
                                          (=Number of Task Managers)
     -ynl,--yarnnodeLabel <arg>           Specify YARN node label for the
YARN
                                          application
     -ynm,--yarnname <arg>                Set a custom name for the
application
                                          on YARN
     -yq,--yarnquery                      Display available YARN resources
                                          (memory, cores)
     -yqu,--yarnqueue <arg>               Specify YARN queue.
     -ys,--yarnslots <arg>                Number of slots per TaskManager
     -yst,--yarnstreaming                 Start Flink in streaming mode
     -yt,--yarnship <arg>                 Ship files in the specified
directory
                                          (t for transfer)
     -ytm,--yarntaskManagerMemory <arg>   Memory per TaskManager Container
with
                                          optional unit (default: MB)
     -yz,--yarnzookeeperNamespace <arg>   Namespace to create the Zookeeper
                                          sub-paths for high availability
mode
     -z,--zookeeperNamespace <arg>        Namespace to create the Zookeeper
                                          sub-paths for high availability
mode


现在下载的Flink 1.8,运行bin/flink run --help,总共只有如下参数,少了yarn-cluster选项:
Action "run" compiles and runs a program.

  Syntax: run [OPTIONS] <jar-file> <arguments>
  "run" action options:
     -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.
     -C,--classpath <url>                 Adds a URL to each user code
                                          classloader  on all nodes in the
                                          cluster. The paths must specify a
                                          protocol (e.g. file://) and be
                                          accessible on all nodes (e.g. by
means
                                          of a NFS share). You can use this
                                          option multiple times for
specifying
                                          more than one URL. The protocol
must
                                          be supported by the {@link
                                          java.net.URLClassLoader}.
     -d,--detached                        If present, runs the job in
detached
                                          mode
     -n,--allowNonRestoredState           Allow to skip savepoint state that
                                          cannot be restored. You need to
allow
                                          this if you removed an operator
from
                                          your program that was part of the
                                          program when the savepoint was
                                          triggered.
     -p,--parallelism <parallelism>       The parallelism with which to run
the
                                          program. Optional flag to
override the
                                          default value specified in the
                                          configuration.
     -q,--sysoutLogging                   If present, suppress logging
output to
                                          standard out.
     -s,--fromSavepoint <savepointPath>   Path to a savepoint to restore
the job
                                          from (for example
                                          hdfs:///flink/savepoint-1537).
     -sae,--shutdownOnAttachedExit        If the job is submitted in
attached
                                          mode, perform a best-effort
cluster
                                          shutdown when the CLI is
terminated
                                          abruptly, e.g., in response to a
user
                                          interrupt, such as typing Ctrl +
C.
  Options for default mode:
     -m,--jobmanager <arg>           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.
     -z,--zookeeperNamespace <arg>   Namespace to create the Zookeeper
sub-paths
                                     for high availability mode


发现,少了yarn-cluster的一些参数,请教下,这是什么原因啊

回复