1996fanrui commented on code in PR #27688:
URL: https://github.com/apache/flink/pull/27688#discussion_r2879299918
##########
flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointITCase.java:
##########
@@ -277,7 +277,15 @@ public UnalignedCheckpointITCase(
@Test
public void execute() throws Exception {
- execute(settings);
+ // Phase 1: Run with WAIT_FOR_CHECKPOINT_AND_CANCEL to produce a
checkpoint
+ settings.setCheckpointGenerationMode(
+ CheckpointGenerationMode.WAIT_FOR_CHECKPOINT_AND_CANCEL);
+ String checkpointPath = super.execute(settings);
+
+ // Phase 2: Restore from the checkpoint and run normally
+ settings.setCheckpointGenerationMode(CheckpointGenerationMode.NONE);
+ settings.setRestoreCheckpoint(checkpointPath);
+ super.execute(settings);
Review Comment:
The new change includes 2 phases, and the first phase is original test case.
I'm not sure if this is what you expected.
--
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]
