Hi, I have an Flink .jar file and I submit it on yarn cluster using the command:
flink run -m yarn-cluster -yn 5 -yjm 768 -ytm 1400 -ys 2 -yqu streamQ my_program.jar According to the submitting command I expect: // It will create 5 containers ----> satisfied // each container should use 2 core --> not satisfied according to the YARN webui but in jobmanager webui it shows each taskmanager has 2 slot // jobmanager should use 768m ram --> satisfied // each taskmanager should use 1400m ram --> satisfied according to the YARN webui but in jobmanager webui it shows for each taskmanager: 767m heap memory and 478m used by Flink Why the number of used cores and memory is not as desired?
