(flink) 01/08: [FLINK-39521][test] Temporarily remove during-recovery flag from ITCase randomization

[fa...@apache.org]

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 <19...@gmail.com>
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;