版本:flink-1.12.4
运行模式: application-mode
执行命令:flink run-application -t yarn-application .....
请问:采用该方式提交flink作业,如何指定 taskManager 的个数。即像采用 yarn-cluster方式条任务时指定的 -yn 参数(该参数经过试验在application mode下不能执行) 。
注意:不是问每个taskManager的任务槽数(-Dtaskmanager.numberOfTaskSlots=XX),而是指定TaskManager的个数。
在 flink run-application 模式下,可以使用 -Dyarn.num-task-managers 参数来指定 taskmanager 的个数,如下所示:
flink run-application -t yarn-application -Dyarn.num-task-managers= .....
其中, 表示 taskmanager 的个数。通过指定该参数,可以控制 taskmanager 的个数,从而实现更好的资源利用和作业性能优化。请注意,该参数只对 yarn 模式有效,在 standalone 模式下无效。