session运行模式

该模式下分为2步，即使用yarn-session.sh申请资源，然后 flink run提交任务。

1、申请资源yarn-session.sh

#在server1执行命令

/usr/local/flink-1.13.5/bin/yarn-session.sh -tm 1024 -n 2 -s 1 -d

#申请2个CPU、2g内存
# -tm 表示每个TaskManager的内存大小
# -n 表示申请2个容器，就是多少个taskmanager  (新版本该参数省略，根据提交job动态调整)
# -s 表示每个TaskManager的slots数量  (新版本该参数省略，根据提交job动态调整)
# -d 表示以后台程序方式运行

2、验证yarn ui

yarn链接地址：http://server1:8088/cluster

3、使用flink run提交任务

需要在server1上执行
#多执行几次看看运行情况，或者运行其他的应用也可以

/usr/local/flink-1.13.5/bin/flink run  /usr/local/flink-1.13.5/examples/batch/WordCount.jar

或

/usr/local/flink-1.13.5/bin/flink run  -c xx.xx.xx.Main /usr/local/flink-1.13.5/examples/batch/WordCount.jar

4、验证flink提交的任务

通过上方的ApplicationMaster(Tracking UI)可以进入Flink的管理界面

5、关闭yarn-session

yarn application -kill application_1688448920799_0001

其它： Flink（二）1.13.5二种部署方式(Standalone、Standalone HA )、四种提交任务方式（前两种及session和per-job）验证详细步骤_一瓢一瓢的饮 alanchan的博客-CSDN博客