rkhachatryan commented on code in PR #24484:
URL: https://github.com/apache/flink/pull/24484#discussion_r1526297069
##########
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:
I wanted to check the log message when checkpoint completion notification is
received.
That notification is not guaranteed to be sent if the job is cancelled right
after the checkpoint, so I added a 2nd checkpoint.
--
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
