zhuzhurk commented on a change in pull request #12423:
URL: https://github.com/apache/flink/pull/12423#discussion_r435878447
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/AbstractExecutionSlotAllocator.java
##########
@@ -105,22 +104,11 @@ protected SlotExecutionVertexAssignment
createAndRegisterSlotExecutionVertexAssi
return slotExecutionVertexAssignment;
}
- /**
- * Calculates the preferred locations for an execution.
- * It will first try to use preferred locations based on state,
- * if null, will use the preferred locations based on inputs.
- */
- protected static CompletableFuture<Collection<TaskManagerLocation>>
calculatePreferredLocations(
+ protected CompletableFuture<Collection<TaskManagerLocation>>
calculatePreferredLocations(
Review comment:
I think it's good to have to allow subclasses to not be aware of the way
to retrieve preferred locations.
----------------------------------------------------------------
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:
us...@infra.apache.org
