This is an automated email from the ASF dual-hosted git repository. fanrui pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 1e8e2a7e826a63cc07940fd0f954d8e857bd02d6 Author: Rui Fan <[email protected]> AuthorDate: Thu Jan 15 17:44:35 2026 +0100 [FLINK-38541][checkpoint] Randomize UNALIGNED_DURING_RECOVERY_ENABLED for testing --- .../main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java | 1 + 1 file changed, 1 insertion(+) diff --git a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java index c8284090264..062754bd785 100644 --- a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java +++ b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java @@ -148,6 +148,7 @@ public class TestStreamEnvironment extends StreamExecutionEnvironment { randomize(conf, CheckpointingOptions.ENABLE_UNALIGNED, true, false); randomize( conf, CheckpointingOptions.UNALIGNED_RECOVER_OUTPUT_ON_DOWNSTREAM, true, false); + randomize(conf, CheckpointingOptions.UNALIGNED_DURING_RECOVERY_ENABLED, true, false); randomize( conf, CheckpointingOptions.ALIGNED_CHECKPOINT_TIMEOUT,
