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 5e02d64bf018c9e3ba1f30ea2ad52a3dfad0e6dc Author: Rui Fan <[email protected]> AuthorDate: Mon Nov 3 22:04:04 2025 +0100 [FLINK-38542][checkpoint] Randomize UNALIGNED_ALLOW_ON_RECOVERY for testing --- .../java/org/apache/flink/streaming/util/TestStreamEnvironment.java | 2 ++ 1 file changed, 2 insertions(+) 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 d8634db02ac..cbf2e9b8f83 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 @@ -145,6 +145,8 @@ public class TestStreamEnvironment extends StreamExecutionEnvironment { // randomize ITTests for enabling unaligned checkpoint if (RANDOMIZE_CHECKPOINTING_CONFIG) { randomize(conf, CheckpointingOptions.ENABLE_UNALIGNED, true, false); + randomize( + conf, CheckpointingOptions.UNALIGNED_RECOVER_OUTPUT_ON_DOWNSTREAM, true, false); randomize( conf, CheckpointingOptions.ALIGNED_CHECKPOINT_TIMEOUT,
