azagrebin opened a new pull request #13181: URL: https://github.com/apache/flink/pull/13181
Track fulfil-ability of required physical slots for all SharedSlot(s) (no matter whether they are created at this bulk or not) with timeout. This ensures we will not wait indefinitely if the required slots for this bulk cannot be fully fulfilled at the same time. - Create a LogicalSlotRequestBulk to track all physical requests and logical slot requests (logical slot requests only which belong to the bulk) - Mark physical slot request fulfilled in LogicalSlotRequestBulk, once its future is done - If any physical slot request fails then clear the LogicalSlotRequestBulk to stop the fulfil-ability check - Schedule a fulfil-ability check in LogicalSlotRequestBulkChecker for the LogicalSlotRequestBulk - In case of timeout cancel/fail the logical slot futures of the bulk in SharedSlot(s) ---------------------------------------------------------------- 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]
