FlinkOnYarnApplication原理

Flink 1.11 引入了一种新的运行模式，即 Application 模式，目前可以支持基于 Hadoop YARN 和 Kubernetes 的 Application 模式。

1. Per-Job 模式：每个作业单独启动1个集群，隔离性好，JM 负载均衡，Job作业main 方法在客户端执行。

   

2. Session 模式：所有作业Job共享1个集群资源，隔离性差，JM 负载瓶颈，每个Job中main 方法在客户端执行。

通过以上两种模式的特点描述，可以看出，main方法都是在客户端执行，社区考虑到在客户端执行 main() 方法来获取 flink 运行时所需的依赖项，并生成 JobGraph，提交到集群的操作都会在实时平台所在的机器上执行，那么将会给服务器造成很大的压力。尤其在大量用户共享客户端时，问题更加突出。

此外这两种模式提交任务的时候会把本地flink的所有jar包先上传到hdfs上相应的临时目录，这个也会带来大量的网络的开销，所以如果任务特别多的情况下，平台的吞吐量将会直线下降。

Application模式使用 bin/flink run-application 提交作业，本质上是Session和Per-Job模式的折衷。

xxxxxxxxxx
#bin/flink run-application参数说明
-t:指定运行模式 "yarn-application","kubernetes-application"