在Yarn上运行flink 1.5

lrl1mhuk  于 2021-06-21  发布在  Flink
关注(0)|答案(1)|浏览(305)

我们正在hadoop 2.6集群上运行flink 1.5.0Yarn会话/bin/yarn-session.sh-n 4-jm 1024-tm 4096-qu但这不会启动任何TaskManager。日志上说flink jobmanager以领导者id 000000开始。。。在jobmanager web界面中也没有任务管理器。当我们向这个jobmanager提交一个flink作业时,一些taskmanager会在执行该作业的web界面上生成。这是flink1.5.0以后的预期行为吗?以同样的方式运行flink1.4.2确实会从启动时产生taskmanagers。

vqlkdk9b

vqlkdk9b1#

是的,flink 1.5中包含了对flink运行时的重写,称为flip-6,它具有您已经注意到的效果。有关flink现在如何与yarn交互的简洁描述,请参阅文档的这一部分。
Flink1.5包含一个配置选项,用于使用以前的作业部署模型,称为遗留模式。

相关问题