edu05 commented on a change in pull request #11952:
URL: https://github.com/apache/flink/pull/11952#discussion_r418310611
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java
##########
@@ -289,21 +270,12 @@ public ExecutionJobVertex(
}
/**
- * Returns a list containing the IDs of all operators contained in this
execution job vertex.
+ * Returns a list containing the ID pairs of all operators contained in
this execution job vertex.
*
- * @return list containing the IDs of all contained operators
+ * @return list containing the ID pairs of all contained operators
*/
- public List<OperatorID> getOperatorIDs() {
- return operatorIDs;
- }
-
- /**
- * Returns a list containing the alternative IDs of all operators
contained in this execution job vertex.
- *
- * @return list containing alternative the IDs of all contained
operators
- */
- public List<OperatorID> getUserDefinedOperatorIDs() {
- return userDefinedOperatorIds;
+ public OperatorIdPairList getOperatorIdPairList() {
Review comment:
done by removing the class altogether
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PendingCheckpoint.java
##########
@@ -371,7 +371,7 @@ public TaskAcknowledgeResult acknowledgeTask(
acknowledgedTasks.add(executionAttemptId);
}
- List<OperatorID> operatorIDs =
vertex.getJobVertex().getOperatorIDs();
+ List<OperatorID> operatorIDs =
vertex.getJobVertex().getOperatorIdPairList().getOperatorIds();
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.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
