flink启动命令参数_Flink命令行 - 1.10

本篇文章大概3155字，阅读时间大约8分钟

结合Flink官方文档，整理关于Flink命令行的操作参数，包含命令行接口和Scala Shell

1

文档编写目的

整理Flink官方文档中命令行接口和scala-shell的内容

在Flink1.10.1集群上进行实操

Flink命令行

Command-Line Interface

Scala Shell

2

Command-Line Interface

Flink的命令行接口主要用来运行达成jar包的Flink应用程序，具体功能如下：

提交Flink应用

取消运行的Flink应用

获取Flink应用的信息

查看Flink集群上的应用(包含运行中和等待的应用)

触发或释放savepoint

Flink命令行详细解释

flink run (这里略过了部分python的参数)

-c,--class Flink应用程序的入口-C,--classpath 指定所有节点都可以访问到的url,可用于多个应用程序都需要的工具类加载-d,--detached 是否使用分离模式，就是提交任务,cli是否退出,加了-d参数,cli会退出-n,--allowNonRestoredState 允许跳过无法还原的savepoint。比如删除了代码中的部分operator-p,--parallelism 执行并行度-s,--fromSavepoint 从savepoint恢复任务-sae,--shutdownOnAttachedExit 以attached模式提交，客户端退出的时候关闭集群

flink yarn-cluster 模式