XComp commented on code in PR #24484:
URL: https://github.com/apache/flink/pull/24484#discussion_r1526327468
##########
flink-tests/src/test/java/org/apache/flink/test/misc/JobIDLoggingITCase.java:
##########
@@ -205,6 +268,8 @@ private static JobID runJob(ClusterClient<?> clusterClient)
throws Exception {
// wait for all tasks ready and then checkpoint
while (true) {
try {
+ clusterClient.triggerCheckpoint(jobId,
CheckpointType.DEFAULT).get();
+ // get checkpoint notification
Review Comment:
:+1: That might be a more descriptive comment than the one in the code right
now.
--
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
