flink run-application模式下,如何设置taskmanager个数

版本: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 模式下无效。