Hi Henry,
If I understand you correctly, you want YARN to allocate 4 vcores per TM
container. You can achieve this by enabling the FairScheduler in YARN
[1][2].
Best,
Gary
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.7/ops/config.html#yarn-containers-vcores
[2]
https://hadoop.ap
Hi Experts,
I am running Flink 1.7.1 program on Yarn 2.7, the
taskmanager.numberOfTaskSlots is set to 4. The parallelism.default is set to 8.
When the program is running, 3 yarn containers is launched, but each of them
only use 1 vcore, I think by default the number of vcores is set to t