执行 flink run 后参数：

参数说明
Action "run" compiles and runs a program.
Syntax: run [OPTIONS] <jar-file> <arguments>"run" action options:-c,--class <classname>                         Class with the program entrypoint ("main" method or"getPlan()" method. Onlyneeded if the JAR file doesnot specify the class in itsmanifest.-C,--classpath <url>                           Adds a URL to each user codeclassloader  on all nodes inthe cluster. The paths mustspecify a protocol (e.g.file://) and be accessibleon all nodes (e.g. by meansof a NFS share). You can usethis option multiple timesfor specifying more than oneURL. The protocol must besupported by the {@linkjava.net.URLClassLoader}.-d,--detached                                  If present, runs the job indetached mode-m,--jobmanager <host:port>                    Address of the JobManager(master) to which toconnect. Use this flag toconnect to a differentJobManager than the onespecified in theconfiguration.-p,--parallelism <parallelism>                 The parallelism with whichto run the program. Optionalflag to override the defaultvalue specified in theconfiguration.-q,--sysoutLogging                             If present, suppress loggingoutput to standard out.-s,--fromSavepoint <savepointPath>             Path to a savepoint to resetthe job back to (for examplefile:///flink/savepoint-1537).-z,--zookeeperNamespace <zookeeperNamespace>   Namespace to create theZookeeper sub-paths for highavailability mode
Options for yarn-cluster mode:-yD <arg>                            Dynamic properties-yd,--yarndetached                   Start detached-yid,--yarnapplicationId <arg>       Attach to running YARN session-yj,--yarnjar <arg>                  Path to Flink jar file-yjm,--yarnjobManagerMemory <arg>    Memory for JobManager Container [inMB]-yn,--yarncontainer <arg>            Number of YARN container to allocate(=Number of Task Managers)-ynm,--yarnname <arg>                Set a custom name for the applicationon YARN-yq,--yarnquery                      Display available YARN resources(memory, cores)-yqu,--yarnqueue <arg>               Specify YARN queue.-ys,--yarnslots <arg>                Number of slots per TaskManager-yst,--yarnstreaming                 Start Flink in streaming mode-yt,--yarnship <arg>                 Ship files in the specified directory(t for transfer)-ytm,--yarntaskManagerMemory <arg>   Memory per TaskManager Container [inMB]-yz,--yarnzookeeperNamespace <arg>   Namespace to create the Zookeepersub-paths for high availability mode-n 10 一共启动10个TaskManager节点-jm 1024 JobManager的内存大小为1024M-tm 2048 TaskManager的内存大小为2048M
-d 使用detached模式进行部署（部署完成后本地命令行可以退出）
-qu default 部署到YARN的default队列中

参考:

https://blog.csdn.net/jerome520zl/article/details/103637811

Flink基础系列6-flink run参数相关推荐

Flink基础系列8-Flink on yarn运行wordcount程序
文章目录环境介绍一.Maven配置二.Java代码编写三.Maven打包并上传四.运行jar文件五.运行其它的class文件参考环境介绍测试服务器CDH 6.3.1版本安装Flink ...
Flink基础系列7-通过Web UI执行jar文件
文章目录环境准备一.准备代码 1.1 maven准备 1.2 Java代码准备二.打包三.通过Web UI执行jar文件 3.1 上传文件环境准备本地Windows环境已安装Flink 1 ...
Flink基础系列20-数据重分区操作
文章目录一.数据重分区参考: 一.数据重分区重分区操作,在DataStream类中可以看到很多Partitioner字眼的类. 其中partitionCustom(-)方法用于自定义重分区. 测 ...
Flink基础系列17-Tranform之多流转换算子
文章目录一.多流转换算子概述 1.1 Split和Select 1.2 Connect和CoMap 1.3 Union 二.代码实现参考: 一.多流转换算子概述多流转换算子一般包括: Split ...
【Flink实战系列】Flink 1.11.1 on yarn 集群搭建教程
前面一篇博客中已经搭建了flink Standalone的集群,需要的可以进去看一下,今天主要来说一下flink on yarn 集群的搭建以及怎么提交任务,之前搭建Flink on yarn的时候用 ...
【Flink实战系列】Flink 提交任务遇到 Server Response Internal server error 怎么排查
很多同学在提交 Flink 任务的时候遇到下面这种报错不知道怎么排查.完全处于懵逼状态,竟一直盯着这个报错看. 记得一定要去 JM 的 logs 里面看详细的报错信息,只看这个 Internal se ...
【Flink实战系列】Flink 本地 Web UI 的配置及使用
当你在本地开发调试 Flink 任务的时候,如果没有搭建集群环境,但是又想要查看 Flink 的 Web UI 该怎么办呢? 其实 Flink 是提供有在本地查看 Flink UI 功能的. 添加依赖 ...
【Flink实战系列】Flink SQL 之 Session Window 的用法
Flink SQL 之 Session Window 的用法 Session Windows 会话窗口分配器按活动的会话对元素进行分组.与翻滚窗口和滑动窗口相比,会话窗口没有重叠,也没有固定的开始和结 ...
【Flink 实战系列】Flink SQL 使用 filesystem connector 同步 Kafka 数据到 HDFS（parquet 格式 + snappy 压缩）
Flink SQL 同步 Kafka 数据到 HDFS(parquet + snappy) 在上一篇文章中,我们用 datastream API 实现了从 Kafka 读取数据写到 HDFS 并且用 ...

Flink基础系列6-flink run参数

参考:

Flink基础系列6-flink run参数相关推荐

最新文章

热门文章