Flink实战案例(五十二): flink 作业提交(二)yarn 提交模式(一) Flink on YARN Session模式

1. Flink on YARN两种方式

Flink on YARN 有两种模式:Session模式和Per-Job模式。在Session模式中多个 JobManager 共享 Dispatcher 和 YarnResourceManager。在这种模式下,需要先向 YARN 申请资源,初始化一个常驻服务在 YARN 上,后续提交的Job都将运行在这个Session上:

而Per-Job模式则相反,一个 JobManager 独享 Dispatcher 和 YarnResourceManager。也就是说每提交一个Job都新建一个Session,不同Job之间的资源是隔离的,不会互相影响:

image.png

想要深入了解的话可以参考官方文档:

2 Flink on YARN Session模式实操

首先将在Flink目录拷贝到当前部署了Hadoop环境的机器上: