zentol opened a new pull request, #21908: URL: https://github.com/apache/flink/pull/21908
Fixes an issue where the distribution of slots across slot-sharing groups did not take the max parallelism of that group into account, due to which some slots were potentially left unused. We now update the number of slots assigned per group dynamically after each group was processed. Before slots are assigned the groups are sorted by the max parallelism in ascending order so we can assign all slots in one pass. As a potential follow-up we could consider an alternative slot distribution pattern where slots are assigned proportional to the max parallelism of the groups. -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
