Hi Alex,
Which Flink version are you using?
AFAIK, since Flink 1.8+, the config option: "-yn" for Flink on YARN job
cluster mode does not take effect(always 1 and would be overridden).
So, the config option "-ys" and "-p" will decide the number of TM.
The first example: -p(20)/-ys(3) should be
Hi all,
Could you list details how Flink job on Yarn resources managed ?
I used command “-p 20 -yn 5 -ys 3 -yjm 2048m -ytm 2048m” to run flink job. I
got
containers vcores
8 22
Task Managers 7 Total Task Slots 21
I used command “-p 20 -yn 7 -ys 4 -yjm 2048m -ytm 2048m” to