【Flink 实战系列】Flink on yarn 为什么 Allocated CPU VCores 显示不正确？

Flink on yarn 为什么 Allocated CPU VCores 显示不正确？

一直有朋友问我这样的问题，在 flink on yarn 集群环境下，提交任务到 yarn，一个 TM 不管我设置多少个 slot，yarn 的 UI 界面 Allocated CPU VCores 一直显示的都是 1 呢？这个问题被问到了好多次，今天就来详细的解释一下原因。

demo

比如用下面的命令提交一个 Flink 任务：

flink run -d --target yarn-per-job \
-Dyarn.application.name=FlinkStreamingBroadcastMysqlDemo \
-Dyarn.application.queue=flink \
-Dpipeline.name=FlinkStreamingBroadcastMysqlDemo \
-Dmetrics.reporter.promgateway.groupingKey="job_name=t
1
2
3
4