Flink on YARN:我如何指定任务管理器的数量



在早期版本的Flink中(例如1.6(,我可以指定使用-n的会话模式和使用-yn的每个作业模式的任务管理器的数量,但这些标志在后来版本的Flnk中不存在(例如1.12(

想知道我应该如何为Flink的新版本设置YARN上的任务管理器数量?或者,我可以使用哪些相关属性来控制Flink使用的资源?

在Flink的较新版本中,资源管理器根据需要动态启动任务管理器,以提供提交的作业请求的插槽数量。每个任务管理器将从flink-conf.yaml或通过yarn-session.sh启动集群时提供的参数中获取其配置。

相关内容

  • 没有找到相关文章

最新更新