This is an automated email from the ASF dual-hosted git repository. 1996fanrui pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit b9cadc24b7dcde4af9bda233c0ce0a2253e2c9f7 Author: Rui Fan <[email protected]> AuthorDate: Mon Jul 6 01:36:00 2026 +0200 [FLINK-39523][test] Restore during-recovery flag randomization; re-enable filtering ITCase TestStreamEnvironment: restore randomize(conf, CHECKPOINTING_DURING_RECOVERY_ENABLED, true, false), closing the transitional randomization window opened when the v1 conversion-migration path was retired. Re-enable RecoveredStateFilteringLargeRecordITCase. From here on the randomized ITCase fleet runs flag-on ~50% against the in-memory backend (same memory profile as base v1, which ran the same randomization with the same heap fallback). The spilling PRs must keep the fleet green -- this is the acceptance bar for "lightweight backend replacement". --- .../java/org/apache/flink/streaming/util/TestStreamEnvironment.java | 6 ++---- .../checkpointing/RecoveredStateFilteringLargeRecordITCase.java | 5 ----- 2 files changed, 2 insertions(+), 9 deletions(-) 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 c51108d7ee2..064ceeccf69 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,10 +148,8 @@ public class TestStreamEnvironment extends StreamExecutionEnvironment { randomize(conf, CheckpointingOptions.ENABLE_UNALIGNED, true, false); randomize( conf, CheckpointingOptions.UNALIGNED_RECOVER_OUTPUT_ON_DOWNSTREAM, true, false); - // FLINK-38544 transitional: CHECKPOINTING_DURING_RECOVERY_ENABLED is temporarily - // removed from randomization while the recovered-channel conversion is reworked - // (the flag-on path is degraded until the StreamTask recovery rework lands); it is - // restored in the checkpoint-coordination-during-recovery PR of this series. + randomize( + conf, CheckpointingOptions.CHECKPOINTING_DURING_RECOVERY_ENABLED, true, false); randomize( conf, CheckpointingOptions.ALIGNED_CHECKPOINT_TIMEOUT, diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/RecoveredStateFilteringLargeRecordITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/RecoveredStateFilteringLargeRecordITCase.java index d916789d8bc..64d4213f012 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/RecoveredStateFilteringLargeRecordITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/RecoveredStateFilteringLargeRecordITCase.java @@ -44,7 +44,6 @@ import org.apache.flink.test.junit5.InjectMiniCluster; import org.apache.flink.test.junit5.MiniClusterExtension; import org.apache.flink.util.TestLoggerExtension; -import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; import org.junit.jupiter.api.extension.RegisterExtension; @@ -81,10 +80,6 @@ import static org.apache.flink.configuration.RestartStrategyOptions.RestartStrat * therefore proof that the invariant held across all buffer cycles. */ @ExtendWith({TestLoggerExtension.class}) -@Disabled( - "FLINK-38544 transitional: this test pins checkpointing-during-recovery on, which is" - + " degraded until the StreamTask recovery rework of this series lands; re-enabled" - + " in the checkpoint-coordination-during-recovery PR.") class RecoveredStateFilteringLargeRecordITCase { private static final int NUM_TASK_MANAGERS = 1;
