Flink 命令行参数介绍_flink run-application参数设置

参考文档：
1、https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/cli/
2、Flink 三种模式 | 不同的执行命令的差异

一、Flink Command | CLI Actions

1.1 客户端命令介绍

Flink 提供了一个命令行界面 (CLI) bin/flink 来运行为 JAR 文件的程序并控制它们的执行

命令行格式，一定要理解命令行的格式，每个 ACTION 都用自己对应的 OPTION（很重要，不然很容易搞混）

# ACTION 必选
# OPTION 可选
# ARGUMENTS 可选

.bin/flink <ACTION> [OPTIONS] [ARGUMENTS]
1
2
3
4
5

flink 中的 Action 有这些：

1.2 使用示例

① ./bin flink run

② ./bin flink run-application

示例 3 ：查看作业的执行计划

# 进入 FLINK 安装目录, 执行如下命令
./bin/flink info \
      -c org.apache.flink.streaming.examples.socket.SocketWindowWordCount \
      examples/streaming/SocketWindowWordCount.jar \
      --port 9000
1
2
3
4
5

示例 4 ：查看执行的作业列表

# 查看该命令的帮助
./bin/flink list -h

# 查看正在执行作业列表(如果你的程序运行在yarn集群上,这个命令可能会报错)
# flink on yarn 时，使用该命令一定要指定 cluster_id ，即可以理解为 jobId
./bin/flink list
1
2
3
4
5
6

为了测试该命令，我们需要启动一个 flink 作业，我们先启动一个会话模式，然后在会话中提交一个作业 (参考该博客启动作业)

https://blog.csdn.net/hell_oword/article/details/120116908

# 查看该会话下的所有运行作业列表
./bin/flink list \
      -a \
      -m yarn-cluster \
      -yid application_1646190502615_0113
1
2
3
4
5

示例 4 ：取消一个作业

https://blog.csdn.net/hell_oword/article/details/120116908

二、Flink Run Command | flink run

2.1 命令介绍

flink run 命令用于编译和执行一个程序

查看命令参数选项

# 命令格式
run [OPTIONS] <jar-file> <arguments>

# 查看命令帮助
./bin/flink run -h
1
2
3
4
5

命令参数分为 4 部分，分别为

$ ./bin/flink run -h
  Syntax: run [OPTIONS] <jar-file> <arguments>
  
  "run" action options:
  ...
  Options for Generic CLI mode:
  ...
  Options for yarn-cluster mode:
  ...
  Options for default mode:
1
2
3
4
5
6
7
8
9
10

① run action options（主要用于设置执行的主类）

② Options for Generic CLI mode

③ Options for yarn-cluster mode（yarn-cluster 模式下的 Options）

④ Options for default mode

2.2 使用示例

示例一：提交一个应用(job分离模式)

1