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 17dfa5fb586cd641959888a8490fa5c984cc85e3 Author: Rui Fan <[email protected]> AuthorDate: Thu Mar 26 23:10:17 2026 +0100 [hotfix] Rename isUnalignedDuringRecoveryEnabled to isCheckpointingDuringRecoveryEnabled --- .../apache/flink/configuration/CheckpointingOptions.java | 4 ++-- .../flink/configuration/CheckpointingOptionsTest.java | 14 +++++++++----- 2 files changed, 11 insertions(+), 7 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 d2ccca8c1bc..a1307b38c51 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 @@ -800,11 +800,11 @@ public class CheckpointingOptions { * execution. * * @param config the configuration to check - * @return {@code true} if unaligned checkpoint during recovery is enabled, {@code false} + * @return {@code true} if unaligned checkpointing during recovery is enabled, {@code false} * otherwise */ @Internal - public static boolean isUnalignedDuringRecoveryEnabled(Configuration config) { + public static boolean isCheckpointingDuringRecoveryEnabled(Configuration config) { if (!config.get(UNALIGNED_RECOVER_OUTPUT_ON_DOWNSTREAM)) { return false; } 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 747f789af35..75c4ec07d23 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 @@ -333,14 +333,16 @@ class CheckpointingOptionsTest { void testIsUnalignedDuringRecoveryEnabled() { // Test when both options are disabled (default) - should return false Configuration defaultConfig = new Configuration(); - assertThat(CheckpointingOptions.isUnalignedDuringRecoveryEnabled(defaultConfig)) + assertThat(CheckpointingOptions.isCheckpointingDuringRecoveryEnabled(defaultConfig)) .as("During-recovery should be disabled by default") .isFalse(); // 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); - assertThat(CheckpointingOptions.isUnalignedDuringRecoveryEnabled(onlyDuringRecoveryConfig)) + assertThat( + CheckpointingOptions.isCheckpointingDuringRecoveryEnabled( + onlyDuringRecoveryConfig)) .as( "During-recovery should be disabled when recover-output-on-downstream is not enabled") .isFalse(); @@ -350,7 +352,7 @@ class CheckpointingOptionsTest { onlyRecoverOnDownstreamConfig.set( CheckpointingOptions.UNALIGNED_RECOVER_OUTPUT_ON_DOWNSTREAM, true); assertThat( - CheckpointingOptions.isUnalignedDuringRecoveryEnabled( + CheckpointingOptions.isCheckpointingDuringRecoveryEnabled( onlyRecoverOnDownstreamConfig)) .as("During-recovery should be disabled when during-recovery option is not enabled") .isFalse(); @@ -359,7 +361,7 @@ class CheckpointingOptionsTest { Configuration bothEnabledConfig = new Configuration(); bothEnabledConfig.set(CheckpointingOptions.UNALIGNED_RECOVER_OUTPUT_ON_DOWNSTREAM, true); bothEnabledConfig.set(CheckpointingOptions.UNALIGNED_DURING_RECOVERY_ENABLED, true); - assertThat(CheckpointingOptions.isUnalignedDuringRecoveryEnabled(bothEnabledConfig)) + assertThat(CheckpointingOptions.isCheckpointingDuringRecoveryEnabled(bothEnabledConfig)) .as( "During-recovery should be enabled when both recover-output-on-downstream and during-recovery are enabled") .isTrue(); @@ -369,7 +371,9 @@ class CheckpointingOptionsTest { explicitlyDisabledConfig.set( CheckpointingOptions.UNALIGNED_RECOVER_OUTPUT_ON_DOWNSTREAM, false); explicitlyDisabledConfig.set(CheckpointingOptions.UNALIGNED_DURING_RECOVERY_ENABLED, true); - assertThat(CheckpointingOptions.isUnalignedDuringRecoveryEnabled(explicitlyDisabledConfig)) + assertThat( + CheckpointingOptions.isCheckpointingDuringRecoveryEnabled( + explicitlyDisabledConfig)) .as( "During-recovery should be disabled when recover-output-on-downstream is explicitly false") .isFalse();
