zentol opened a new pull request #14851:
URL: https://github.com/apache/flink/pull/14851
Adds the `SlotAllocator`, one of the core components of the declarative
scheduler which provides the following capabilities:
* determine the amount of required resources given a set of vertices to
scheduled
* determine the parallelism a set of vertices could be run with given a set
of free slots
* reserves slots for a set of vertices based on the previously determined
parallelism.
The only implementation is the `SlotSharingSlotAllocator`, which accounts
for slot-sharing in all of these methods.
Differences from the FLIP:
* `#assignResources` returns a plain `Map<JobVertexID, LogicalSlot>` instead
of a `ParallelismAndResourceAssignments`, because the information about the
parallelism is already accessible from the result of `#determineParallelism`.
* As such the scheduler can construct a
`ParallelismAndResourceAssignments` from the results of both methods.
* `#assignResources` no longer accepts the `JobInformation` or `freeSlots`,
as these were currently unused.
* `VertexAssignment` was renamed to `VertexParallelism`
----------------------------------------------------------------
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]
