mukul-8 commented on code in PR #27767:
URL: https://github.com/apache/flink/pull/27767#discussion_r2935604741
##########
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/SchedulerTestingUtils.java:
##########
@@ -340,6 +340,28 @@ public static void waitForCompletedCheckpoint(final
SchedulerNG scheduler) throw
RETRY_ATTEMPTS);
}
+ /**
+ * Waits until all task executions in the given ExecutionGraph reach
RUNNING state.
+ *
+ * @param executionGraph the ExecutionGraph to check
+ * @throws Exception if the condition is not met within the timeout period
Review Comment:
Thanks for review. This method ensures tasks are in RUNNING state before
triggering the checkpoint, so everything is in sync. Locally, the entire test
completes in under 1 second. The timeout is 60 seconds, globally defined in
this class, consistent with other wait methods.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
