zentol opened a new pull request #13964: URL: https://github.com/apache/flink/pull/13964
Based on #13722. This PR adds the final bit declarative resource management: the `DeclarativeSlotPoolBridge` which acts as a glue between the declarative resource management and current SlotRequest-based scheduler. The bridge essentially maps every incoming slot request, be it for a new or an existing slot, to a requirement increase, and every slot release/free to a requirement reduction. When allocating a new slot the bridge returns a slot future. Whenever a new slot is offered to the JobMaster the bridge tries to fulfill any non-completed slot futures with the new slots. ---------------------------------------------------------------- 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]
