Myracle commented on issue #6734: [FLINK-9455][RM] Add support for multi task 
slot TaskExecutors
URL: https://github.com/apache/flink/pull/6734#issuecomment-571100737
 
 
   @tillrohrmann Thank you for your reply. Before your change, Flink calculate 
pendingTaskManagerSlots(==numPendingContainerRequests * numberOfTaskSlots) in 
the class YarnResourceManager. Flink will only request containers from yarn 
when pendingTaskManagerSlots is bigger than pendingTaskManagerSlots. It means 
that Flink will request resources only when total requested slots can not 
satisfy current's requirement. There is another issue ([FLINK-9567][yarn] 
Before requesting new containers always check if it is required). Does 
FLINK-9567 resolve the same problem? What's the difference between your issue 
and FLINK-9567? Thank you.

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
[email protected]


With regards,
Apache Git Services

Reply via email to