1996fanrui commented on code in PR #27254:
URL: https://github.com/apache/flink/pull/27254#discussion_r2564987935
##########
flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointRescaleITCase.java:
##########
@@ -611,21 +617,34 @@ public UnalignedCheckpointRescaleITCase(
this.sourceSleepMs = sourceSleepMs;
}
+ /**
+ * Tests unaligned checkpoint rescaling behavior.
+ *
+ * <p>Prescale phase: Job fails when completedCheckpoints >=
minCheckpoints/2 via FailingMapper.
+ * Generates checkpoint for rescale test.
+ *
+ * <p>Postscale phase: Job restores from checkpoint with different
parallelism, failovers once,
+ * and finishes after source generates all records.
Review Comment:
The second job expects failover once, and finishes after source generates
all records. So removing
`@ThrowableAnnotation(ThrowableType.NonRecoverableError)` for `TestException`.
Also, I introduced `ExpectedFinalJobStatus` in `UnalignedSettings` to check
the final `JobStatus`.
--
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]
