zhuzhurk commented on a change in pull request #15229:
URL: https://github.com/apache/flink/pull/15229#discussion_r742598366
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/ExecutionSlotAllocationContext.java
##########
@@ -67,4 +68,14 @@
* @return all co-location groups in the job
*/
Set<CoLocationGroup> getCoLocationGroups();
+
+ /**
+ * Returns all allocations to reserve. These allocations/slots were used
to run certain vertices
+ * and reserving them can prevent other vertices to take these slots and
thus help vertices to
+ * be deployed into their previous slots again after failover. It is
needed if {@link
+ * CheckpointingOptions#LOCAL_RECOVERY} is enabled.
+ *
+ * @return all allocations to reserve
+ */
+ Set<AllocationID> getAllocationsToReserve();
Review comment:
done.
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java
##########
@@ -669,6 +704,11 @@ public SchedulingTopology getSchedulingTopology() {
public Optional<TaskManagerLocation>
getStateLocation(ExecutionVertexID executionVertexId) {
return stateLocationRetriever.getStateLocation(executionVertexId);
}
+
+ @Override
+ public Set<AllocationID> getAllocationsToReserve() {
Review comment:
done.
--
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]
