说明

flink on yarn 的 session 模式中，用于 启动 flink 服务

依赖 yarn

依赖 yarn，需要先启动 yarn

/program/bin/hadoop.sh start

查看所有参数

cd /program/flink-1.12.5

执行下面命令，可以查看所有参数：

bin/yarn-session.sh -help

显示如下：

参数解释

bin/yarn-session.sh

有下面参数：

-n 2 表示指定两个容器 
-jm 1024 表示jobmanager 1024M内存 
-tm 1024表示taskmanager 1024M内存 
-d 任务后台运行 
-nm,--name  YARN上为一个自定义的应用设置一个名字
-q,--query  显示yarn中可用的资源 (内存, cpu核数)
-z,--zookeeperNamespace <arg>   针对HA模式在zookeeper上创建NameSpace
-id,--applicationId <yarnAppId>   YARN集群上的任务id，附着到一个后台运行的yarn session中
-qu,--queue <arg>    指定 YARN queue
-s 表示每个TaskManager的slots数量

例子

命令

bin/yarn-session.sh -n 2 -jm 1024 -tm 1024 -d

解释：

• -n 2： 表示申请2个容器，这里指的就是多少个taskmanager
• -jm 1024： 表示jobmanager 的内存大小
• -d： 表示以后台程序方式运行

命令

bin/yarn-session.sh -n 2 -tm 800 -s 1 -d

解释：

• -n 2： 表示申请2个容器，这里指的就是多少个taskmanager
• -tm 800： 表示每个TaskManager的内存大小
• -s 1： 表示每个TaskManager的slots数量
• -d： 表示以后台程序方式运行

指定yarn队列

yarn-session.sh -qu root.default