GJL commented on a change in pull request #11213: [FLINK-16276][tests]
Introduce a builder and factory methods to create DefaultScheduler for testing
URL: https://github.com/apache/flink/pull/11213#discussion_r385132307
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java
##########
@@ -280,23 +281,8 @@ private ExecutionGraph createExecutionGraph(
failoverStrategy);
}
- /**
- * @deprecated Direct access to the execution graph by scheduler
implementations is discouraged
- * because currently the execution graph has various features and
responsibilities that a
- * scheduler should not be concerned about. The following specialized
abstractions to the
- * execution graph and accessors should be preferred over direct access:
- * <ul>
- * <li>{@link #getSchedulingTopology()}
- * <li>{@link #getFailoverTopology()}
- * <li>{@link #getInputsLocationsRetriever()}
- * <li>{@link #getExecutionVertex(ExecutionVertexID)}
- * <li>{@link #getExecutionVertexId(ExecutionAttemptID)}
- * <li>{@link #getExecutionVertexIdOrThrow(ExecutionAttemptID)}
- * </ul>
- * Currently, only {@link LegacyScheduler} requires direct access to
the execution graph.
- */
- @Deprecated
- protected ExecutionGraph getExecutionGraph() {
+ @VisibleForTesting
+ public ExecutionGraph getExecutionGraph() {
Review comment:
Regardless, I don't think we should remove the comment entirely. There is a
reason why helper methods such as `getExecutionVertex()` were introduced. There
is business logic inside the `ExecutionGraph` and I would not want anyone to
call it directly from the scheduler. We can add `@VisibleForTesting` but for me
it does not necessarily mean that calling the method from production code is
discouraged.
----------------------------------------------------------------
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]
With regards,
Apache Git Services
