davidradl commented on code in PR #25798:
URL: https://github.com/apache/flink/pull/25798#discussion_r1890444834
##########
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/AccessExecutionGraph.java:
##########
@@ -199,4 +206,12 @@ public interface AccessExecutionGraph extends
JobStatusProvider {
* @return The changelog storage name, or an empty Optional in the case of
batch jobs
*/
Optional<String> getChangelogStorageName();
+
+ /**
+ * Retrieves the count of pending operators waiting to be transferred to
job vertices in the
+ * adaptive execution of batch jobs.
+ *
+ * @return the number of pending operators.
+ */
+ int getPendingOperatorCount();
Review Comment:
if this is batch specific - batch should be in the method name
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
