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

Question

版本:flink-1.12.4
运行模式: application-mode

执行命令：flink run-application -t yarn-application  .....
请问：采用该方式提交flink作业，如何指定 taskManager 的个数。即像采用 yarn-cluster方式条任务时指定的 -yn 参数（该参数经过试验在application mode下不能执行） 。

注意:不是问每个taskManager的任务槽数(-Dtaskmanager.numberOfTaskSlots=XX)，而是指定TaskManager的个数。

Answer 1

在 flink run-application 模式下，可以使用 -Dyarn.num-task-managers 参数来指定 taskmanager 的个数，如下所示：

flink run-application -t yarn-application -Dyarn.num-task-managers= .....

其中， 表示 taskmanager 的个数。通过指定该参数，可以控制 taskmanager 的个数，从而实现更好的资源利用和作业性能优化。请注意，该参数只对 yarn 模式有效，在 standalone 模式下无效。