在早期版本的Flink中(例如1.6(,我可以指定使用-n
的会话模式和使用-yn
的每个作业模式的任务管理器的数量,但这些标志在后来版本的Flnk中不存在(例如1.12(
想知道我应该如何为Flink的新版本设置YARN上的任务管理器数量?或者,我可以使用哪些相关属性来控制Flink使用的资源?
在Flink的较新版本中,资源管理器根据需要动态启动任务管理器,以提供提交的作业请求的插槽数量。每个任务管理器将从flink-conf.yaml或通过yarn-session.sh
启动集群时提供的参数中获取其配置。