GJL commented on a change in pull request #11752:
URL: https://github.com/apache/flink/pull/11752#discussion_r416632920
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/AccessExecutionVertex.java
##########
@@ -85,4 +86,11 @@
*/
@Nullable
AccessExecution getPriorExecutionAttempt(int attemptNumber);
+
+ /**
+ * Returns prior executions for this execution vertex.
+ *
+ * @return prior executions for this execution vertex
+ */
+ EvictingBoundedList<ArchivedExecution> getPriorExecutionAttempts();
Review comment:
I think it's not ideal to expose the mutable backing
`EvictingBoundedList` from `AccessExecutionVertex`, which aims at being
read-only. We can copy the items in the `EvictingBoundedList` into a
`List<ArchivedExecution>` and make the result immutable.
----------------------------------------------------------------
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]
