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 4afea389445a7b72faf0d7cdb58d4295e5eec127 Author: Rui Fan <[email protected]> AuthorDate: Mon Jul 6 00:21:26 2026 +0200 [FLINK-39521][test] Temporarily remove during-recovery flag from ITCase randomization Drop the randomize(conf, CHECKPOINTING_DURING_RECOVERY_ENABLED, true, false) line from TestStreamEnvironment.randomizeConfiguration (the flag stays at its default false unless a test sets it explicitly) and @Disabled the explicitly flag-on RecoveredStateFilteringLargeRecordITCase. Rationale: a following commit of this PR retires the v1 conversion-migration path, so ~50% of randomized ITCases would otherwise run flag-on and fail until the StreamTask recovery rework and the checkpoint-coordination-during-recovery PRs land. The randomization and the ITCase are restored in the coordination PR (PR4 of the series). --- .../java/org/apache/flink/streaming/util/TestStreamEnvironment.java | 6 ++++-- .../checkpointing/RecoveredStateFilteringLargeRecordITCase.java | 5 +++++ 2 files changed, 9 insertions(+), 2 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 064ceeccf69..c51108d7ee2 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,8 +148,10 @@ 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.CHECKPOINTING_DURING_RECOVERY_ENABLED, 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.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 64d4213f012..d916789d8bc 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,6 +44,7 @@ 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; @@ -80,6 +81,10 @@ 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;
