[FLINK-17017] Implements bulk allocation for physical slots

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.11.0
• Fix Version/s: 1.12.0
• Component/s: Runtime / Coordination
• Labels: pull-request-available
• Assignee: Zhu Zhu
• Reporter: Zhu Zhu
• Created: 07/Apr/20 06:27
• Updated: 11/Jun/20 15:08
• Resolved: 11/Jun/20 15:08

Description

SlotProvider should support bulk slot allocation so that we can check to see if the resource requirements of a slot request bulk can be fulfilled at the same time.

The SlotProvider interface should be extended with an bulk slot allocation method which accepts a bulk of slot requests as one of the parameters.

CompletableFuture<Collection<PhysicalSlotRequest.Result>> allocatePhysicalSlots(
  Collection<PhysicalSlotRequest> slotRequests,
  Time timeout);
 
class PhysicalSlotRequest {
  SlotRequestId slotRequestId;
  SlotProfile slotProfile;
  boolean slotWillBeOccupiedIndefinitely;

  class Result {
    SlotRequestId slotRequestId;
    PhysicalSlot physicalSlot;
  }
}

More details see FLIP-119#Bulk Slot Allocation

Issue Links

• links to: GitHub Pull Request #12031
• links to: GitHub Pull Request #12375