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 0ee8efcac2416a85eae2c7957bdb22a6564f6ed8 Author: Rui Fan <[email protected]> AuthorDate: Mon Apr 13 14:13:17 2026 +0200 [hotfix] Rename UNALIGNED_DURING_RECOVERY_ENABLED to CHECKPOINTING_DURING_RECOVERY_ENABLED --- .../java/org/apache/flink/configuration/CheckpointingOptions.java | 4 ++-- .../org/apache/flink/configuration/CheckpointingOptionsTest.java | 8 +++++--- .../org/apache/flink/streaming/util/TestStreamEnvironment.java | 3 ++- 3 files changed, 9 insertions(+), 6 deletions(-) diff --git a/flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java b/flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java index dbf9e3bb741..fb653120944 100644 --- a/flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java +++ b/flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java @@ -671,7 +671,7 @@ public class CheckpointingOptions { @Experimental @Documentation.Section(Documentation.Sections.COMMON_CHECKPOINTING) - public static final ConfigOption<Boolean> UNALIGNED_DURING_RECOVERY_ENABLED = + public static final ConfigOption<Boolean> CHECKPOINTING_DURING_RECOVERY_ENABLED = ConfigOptions.key("execution.checkpointing.during-recovery.enabled") .booleanType() .defaultValue(false) @@ -807,6 +807,6 @@ public class CheckpointingOptions { if (!config.get(UNALIGNED_RECOVER_OUTPUT_ON_DOWNSTREAM)) { return false; } - return config.get(UNALIGNED_DURING_RECOVERY_ENABLED); + return config.get(CHECKPOINTING_DURING_RECOVERY_ENABLED); } } diff --git a/flink-core/src/test/java/org/apache/flink/configuration/CheckpointingOptionsTest.java b/flink-core/src/test/java/org/apache/flink/configuration/CheckpointingOptionsTest.java index 7f895ef1e51..2334c71fd29 100644 --- a/flink-core/src/test/java/org/apache/flink/configuration/CheckpointingOptionsTest.java +++ b/flink-core/src/test/java/org/apache/flink/configuration/CheckpointingOptionsTest.java @@ -339,7 +339,8 @@ class CheckpointingOptionsTest { // Test when during-recovery is enabled but recover-output-on-downstream is disabled Configuration onlyDuringRecoveryConfig = new Configuration(); - onlyDuringRecoveryConfig.set(CheckpointingOptions.UNALIGNED_DURING_RECOVERY_ENABLED, true); + onlyDuringRecoveryConfig.set( + CheckpointingOptions.CHECKPOINTING_DURING_RECOVERY_ENABLED, true); assertThat( CheckpointingOptions.isCheckpointingDuringRecoveryEnabled( onlyDuringRecoveryConfig)) @@ -360,7 +361,7 @@ class CheckpointingOptionsTest { // Test when both options are enabled - should return true Configuration bothEnabledConfig = new Configuration(); bothEnabledConfig.set(CheckpointingOptions.UNALIGNED_RECOVER_OUTPUT_ON_DOWNSTREAM, true); - bothEnabledConfig.set(CheckpointingOptions.UNALIGNED_DURING_RECOVERY_ENABLED, true); + bothEnabledConfig.set(CheckpointingOptions.CHECKPOINTING_DURING_RECOVERY_ENABLED, true); assertThat(CheckpointingOptions.isCheckpointingDuringRecoveryEnabled(bothEnabledConfig)) .as( "During-recovery should be enabled when both recover-output-on-downstream and during-recovery are enabled") @@ -370,7 +371,8 @@ class CheckpointingOptionsTest { Configuration explicitlyDisabledConfig = new Configuration(); explicitlyDisabledConfig.set( CheckpointingOptions.UNALIGNED_RECOVER_OUTPUT_ON_DOWNSTREAM, false); - explicitlyDisabledConfig.set(CheckpointingOptions.UNALIGNED_DURING_RECOVERY_ENABLED, true); + explicitlyDisabledConfig.set( + CheckpointingOptions.CHECKPOINTING_DURING_RECOVERY_ENABLED, true); assertThat( CheckpointingOptions.isCheckpointingDuringRecoveryEnabled( explicitlyDisabledConfig)) 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 062754bd785..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,7 +148,8 @@ 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.CHECKPOINTING_DURING_RECOVERY_ENABLED, true, false); randomize( conf, CheckpointingOptions.ALIGNED_CHECKPOINT_TIMEOUT,
