MAPREDUCE服务 MRS-Flink Client CLI介绍:常用CLI

时间:2024-06-19 16:04:42

常用CLI

Flink常用的CLI如下所示:

  1. yarn-session.sh
    • 可以使用yarn-session.sh启动一个常驻的Flink集群,接受来自客户端提交的任务。启动一个有3个TaskManager实例的Flink集群示例如下:
      bin/yarn-session.sh -n 3
    • yarn-session.sh的其他参数可以通过以下命令获取:
      bin/yarn-session.sh -help
  2. Flink
    • 使用flink命令可以提交Flink作业,作业既可以被提交到一个常驻的Flink集群上,也可以使用单机模式运行。
      • 提交到常驻Flink集群上的一个示例如下:
        bin/flink run examples/streaming/WindowJoin.jar

        用户在用该命令提交任务前需要先用yarn-session启动Flink集群。

      • 以单机模式运行作业的一个示例如下:
        bin/flink run -m yarn-cluster -yn 2 examples/streaming/WindowJoin.jar

        通过参数-m yarn-cluster使作业以单机模式运行,-yn表示TaskManager的数量。

    • flink脚本的其他参数可以通过以下命令获取:
      bin/flink --help
support.huaweicloud.com/devg-mrs/mrs_06_0416.html