• Flink命令参数释义 ``` ./flink [OPTIONS] [ARGUMENTS]

    可以使用以下操作:

    命令 “run” 编译并运行程序。

    Syntax: run [OPTIONS] “run” action options: -c,—class 程序入口类 (“main” 方法 或 “getPlan()” 方法) 仅在 JAR 文件没有在 manifest 中指定类的时候使用 -C,—classpath 在群集中的所有节点上向每个用户代码类加载器添加URL。 路径必须指定协议(例如文件://),并且可以在所有节点上访问(例如,通过NFS共享)。 您可以多次使用此选项来指定多个URL。该协议必须由 {@link java.net.URLClassLoader} 支持。 -d,—detached 以独立模式运行任务 -n,—allowNonRestoredState 允许跳过无法还原的保存点状态。 当触发保存点的时候, 你需要允许这个行为如果以从你的应用程序中移除一个算子 -p,—parallelism 运行程序的并行度。 可以选择覆盖配置中指定的默认值。 -q,—sysoutLogging 将日志输出到标准输出 -s,—fromSavepoint 从保存点的路径中恢复作业 (例如 hdfs:///flink/savepoint-1537) Options for yarn-cluster mode: -d,—detached 以独立模式运行任务 -m,—jobmanager 连接 JobManager(主)的地址。 使用此标志连接一个不同的 JobManager 在配置中指定的 -yD 使用给定属性的值 -yd,—yarndetached 以独立模式运行任务(过期的;用 non-YARN 选项代替) -yh,—yarnhelp Yarn session CLI 的帮助信息 -yid,—yarnapplicationId 用来运行 YARN Session 的 ID -yj,—yarnjar Flink jar 文件的路径 -yjm,—yarnjobManagerMemory JobManager 容器的内存可选单元(默认值: MB) -yn,—yarncontainer 分配 YARN 容器的数量(=TaskManager 的数量) -ynm,—yarnname 给应用程序一个自定义的名字显示在 YARN 上 -yq,—yarnquery 显示 YARN 的可用资源(内存,队列) -yqu,—yarnqueue 指定 YARN 队列 -ys,—yarnslots 每个 TaskManager 的槽位数量 -yst,—yarnstreaming 以流式处理方式启动 Flink -yt,—yarnship 在指定目录中传输文件 (t for transfer) -ytm,—yarntaskManagerMemory 每个 TaskManager 容器的内存可选单元(默认值: MB) -yz,—yarnzookeeperNamespace 用来创建高可用模式的 Zookeeper 的子路径的命名空间。 -ynl,—yarnnodeLabel 指定 YARN 应用程序 YARN 节点标签 -z,—zookeeperNamespace 用来创建高可用模式的 Zookeeper 的子路径的命名空间。

    Options for default mode: -m,—jobmanager 连接 JobManager(主)的地址。 使用此标志连接一个不同的 JobManager 在配置中指定的。 -z,—zookeeperNamespace 用来创建高可用模式的 Zookeeper 的子路径的命名空间。

    Action “info” 显示程序的优化执行计划(JSON).

    Syntax: info [OPTIONS] “info” action options: -c,—class 具有程序入口的类 (“main” 方法 或 “getPlan()” 方法) 仅在如果 JAR 文件没有在 manifest 中指定类的时候使用 -p,—parallelism 运行程序的并行度。 可以选择覆盖配置中指定的默认值。

    Action “list” 罗列出正在运行和调度的作业

    Syntax: list [OPTIONS] “list” action options: -r,—running 只显示运行中的程序和他们的 JobID -s,—scheduled 只显示调度的程序和他们的 JobID Options for yarn-cluster mode: -m,—jobmanager 连接 JobManager(主)的地址。 使用此标志连接一个不同的 JobManager 在配置中指定的。 -yid,—yarnapplicationId 用来运行 YARN Session 的 ID。 -z,—zookeeperNamespace 用来创建高可用模式的 Zookeeper 的子路径的命名空间。

    Options for default mode: -m,—jobmanager 连接 JobManager(主)的地址。 使用此标志连接一个不同的 JobManager 在配置中指定的。 -z,—zookeeperNamespace 用来创建高可用模式的 Zookeeper 的子路径的命名空间。

    Action “stop” 停止正在运行的程序 (仅限流式处理作业)

    Syntax: stop [OPTIONS] “stop” action options:

    Options for yarn-cluster mode: -m,—jobmanager 连接 JobManager(主)的地址。 使用此标志连接一个不同的 JobManager 在配置中指定的。 -yid,—yarnapplicationId 用来运行 YARN Session 的 ID。 -z,—zookeeperNamespace 用来创建高可用模式的 Zookeeper 的子路径的命名空间。

    Options for default mode: -m,—jobmanager 连接 JobManager(主)的地址。 使用此标志连接一个不同的 JobManager 在配置中指定的。 -z,—zookeeperNamespace 用来创建高可用模式的 Zookeeper 的子路径的命名空间。

    Action “cancel” 取消正在运行的程序。

    Syntax: cancel [OPTIONS] “cancel” action options: -s,—withSavepoint 触发保存点和取消作业。 目标目录是可选的。 如果没有指定目录,使用默认配置 (state.savepoints.dir)。 Options for yarn-cluster mode: -m,—jobmanager 连接 JobManager(主)的地址。 使用此标志连接一个不同的 JobManager 在配置中指定的。 -yid,—yarnapplicationId 用来运行 YARN Session 的 ID。 -z,—zookeeperNamespace 用来创建高可用模式的 Zookeeper 的子路径的命名空间。

    Options for default mode: -m,—jobmanager 连接 JobManager(主)的地址。 使用此标志连接一个不同的 JobManager 在配置中指定的。 -z,—zookeeperNamespace 用来创建高可用模式的 Zookeeper 的子路径的命名空间。

    Action “savepoint” 触发运行作业的保存点,或处理现有作业。

    Syntax: savepoint [OPTIONS] [] “savepoint” action options: -d,—dispose 保存点的处理路径。 -j,—jarfile Flink 程序的 JAR 文件。 Options for yarn-cluster mode: -m,—jobmanager 连接 JobManager(主)的地址。 使用此标志连接一个不同的 JobManager 在配置中指定的。 -yid,—yarnapplicationId 用来运行 YARN Session 的 ID。 -z,—zookeeperNamespace 用来创建高可用模式的 Zookeeper 的子路径的命名空间。

    Options for default mode: -m,—jobmanager 连接 JobManager(主)的地址。 使用此标志连接一个不同的 JobManager 在配置中指定的。 -z,—zookeeperNamespace 用来创建高可用模式的 Zookeeper 的子路径的命名空间。

    Action “modify” 修改正在运行的作业 (例如:修改并行度).

    Syntax: modify [OPTIONS] “modify” action options: -h,—help 用来显示命令行的帮助信息。 -p,—parallelism 指定作业新的并行度。 -v,—verbose 这个选项过期了 Options for yarn-cluster mode: -m,—jobmanager 连接 JobManager(主)的地址。 使用此标志连接一个不同的 JobManager 在配置中指定的。 -yid,—yarnapplicationId 用来运行 YARN Session 的 ID。 -z,—zookeeperNamespace 用来创建高可用模式的 Zookeeper 的子路径的命名空间。

    Options for default mode: -m,—jobmanager 要连接的JobManager(主节点)的地址。 使用此标志可连接到与配置中指定的不同的 JobManager。 -z,—zookeeperNamespace 用来创建高可用模式的 Zookeeper 的子路径的命名空间。 ```