锐客网

  1. 首页 > it技术 > >

Flink中bin/flink命令参考

bin/flink
./flink[OPTIONS] [ARGUMENTS] The following actions are available:
Action "run" compiles and runs a program.
Syntax: run [OPTIONS] "run" action options: -c,--class 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 Adds a URL to each user code classloaderon 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,--detachedIf present, runs the job in detached mode -n,--allowNonRestoredStateAllow 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 【Flink中bin/flink命令参考】The parallelism with which to run the program. Optional flag to override the default value specified in the configuration. -q,--sysoutLoggingIf present, suppress logging output to standard out. -s,--fromSavepointPath to a savepoint to restore the job from (for example hdfs:///flink/savepoint-1537). -sae,--shutdownOnAttachedExitIf 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 yarn-cluster mode: -d,--detachedIf present, runs the job in detached mode -m,--jobmanagerAddress 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,--shutdownOnAttachedExitIf 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 use value for given property -yd,--yarndetachedIf present, runs the job in detached mode (deprecated; use non-YARN specific option instead) -yh,--yarnhelpHelp for the Yarn session CLI. -yid,--yarnapplicationIdAttach to running YARN session -yj,--yarnjarPath to Flink jar file -yjm,--yarnjobManagerMemoryMemory for JobManager Container with optional unit (default: MB) -yn,--yarncontainerNumber of YARN container to allocate (=Number of Task Managers) -ynm,--yarnnameSet a custom name for the application on YARN -yq,--yarnqueryDisplay available YARN resources (memory, cores) -yqu,--yarnqueueSpecify YARN queue. -ys,--yarnslotsNumber of slots per TaskManager -yst,--yarnstreamingStart Flink in streaming mode -yt,--yarnshipShip files in the specified directory (t for transfer) -ytm,--yarntaskManagerMemoryMemory per TaskManager Container with optional unit (default: MB) -yz,--yarnzookeeperNamespaceNamespace to create the Zookeeper sub-paths for high availability mode -ynl,--yarnnodeLabelSpecify YARN node label for the YARN application -z,--zookeeperNamespaceNamespace to create the Zookeeper sub-paths for high availability modeOptions for default mode: -m,--jobmanagerAddress 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,--zookeeperNamespaceNamespace to create the Zookeeper sub-paths for high availability modeAction "info" shows the optimized execution plan of the program (JSON).Syntax: info [OPTIONS] "info" action options: -c,--class 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. -p,--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 scheduled programs.Syntax: list [OPTIONS] "list" action options: -r,--runningShow only running programs and their JobIDs -s,--scheduledShow only scheduled programs and their JobIDs Options for yarn-cluster mode: -m,--jobmanagerAddress of the JobManager (master) to which to connect. Use this flag to connect to a different JobManager than the one specified in the configuration. -yid,--yarnapplicationIdAttach to running YARN session -z,--zookeeperNamespaceNamespace to create the Zookeeper sub-paths for high availability modeOptions for default mode: -m,--jobmanagerAddress 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,--zookeeperNamespaceNamespace to create the Zookeeper sub-paths for high availability modeAction "stop" stops a running program (streaming jobs only).Syntax: stop [OPTIONS] "stop" action options:Options for yarn-cluster mode: -m,--jobmanagerAddress of the JobManager (master) to which to connect. Use this flag to connect to a different JobManager than the one specified in the configuration. -yid,--yarnapplicationIdAttach to running YARN session -z,--zookeeperNamespaceNamespace to create the Zookeeper sub-paths for high availability modeOptions for default mode: -m,--jobmanagerAddress 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,--zookeeperNamespaceNamespace to create the Zookeeper sub-paths for high availability modeAction "cancel" cancels a running program.Syntax: cancel [OPTIONS] "cancel" action options: -s,--withSavepoint Trigger savepoint and cancel job. The target directory is optional. If no directory is specified, the configured default directory (state.savepoints.dir) is used. Options for yarn-cluster mode: -m,--jobmanagerAddress of the JobManager (master) to which to connect. Use this flag to connect to a different JobManager than the one specified in the configuration. -yid,--yarnapplicationIdAttach to running YARN session -z,--zookeeperNamespaceNamespace to create the Zookeeper sub-paths for high availability modeOptions for default mode: -m,--jobmanagerAddress 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,--zookeeperNamespaceNamespace to create the Zookeeper sub-paths for high availability modeAction "savepoint" triggers savepoints for a running job or disposes existing ones.Syntax: savepoint [OPTIONS] [] "savepoint" action options: -d,--disposePath of savepoint to dispose. -j,--jarfile Flink program JAR file. Options for yarn-cluster mode: -m,--jobmanagerAddress of the JobManager (master) to which to connect. Use this flag to connect to a different JobManager than the one specified in the configuration. -yid,--yarnapplicationIdAttach to running YARN session -z,--zookeeperNamespaceNamespace to create the Zookeeper sub-paths for high availability modeOptions for default mode: -m,--jobmanagerAddress 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,--zookeeperNamespaceNamespace to create the Zookeeper sub-paths for high availability modeAction "modify" modifies a running job (e.g. change of parallelism).Syntax: modify [OPTIONS] "modify" action options: -h,--helpShow the help message for the CLI Frontend or the action. -p,--parallelism New parallelism for the specified job. -v,--verboseThis option is deprecated. Options for yarn-cluster mode: -m,--jobmanagerAddress of the JobManager (master) to which to connect. Use this flag to connect to a different JobManager than the one specified in the configuration. -yid,--yarnapplicationIdAttach to running YARN session -z,--zookeeperNamespaceNamespace to create the Zookeeper sub-paths for high availability modeOptions for default mode: -m,--jobmanagerAddress 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,--zookeeperNamespaceNamespace to create the Zookeeper sub-paths for high availability mode

    推荐阅读


    上一篇：1002自省

    下一篇：iOS-事件传递与响应