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 d6858ffbbd7d613cfda2491a2375aa028f8dccea Author: Rui Fan <[email protected]> AuthorDate: Thu Apr 23 11:25:31 2026 +0200 [FLINK-39519][tests] Raise UnalignedCheckpointRescaleWithMixedExchangesITCase segment size to MIN_PAGE_SIZE The test set TaskManagerOptions.MEMORY_SEGMENT_SIZE to 1 KB at the job level to shrink per-buffer record count and speed up recovery/aligned drain. However, StreamTask#createRecordFilterContext reads this option from the job configuration via ConfigurationParserUtils#getPageSize, which enforces MemoryManager.MIN_PAGE_SIZE (4 KB). When TestStreamEnvironment.randomizeConfiguration happens to set both UNALIGNED_RECOVER_OUTPUT_ON_DOWNSTREAM=true and CHECKPOINTING_DURING_RECOVERY_ENABLED=true for a given parameterized invocation (deterministically driven by the test-name seed), the page size check throws IllegalConfigurationException during channel-state recovery and fails the sub-test. Today this reliably hits sub-test [3]; other indices pass only because their seed draws at least one of the flags as false. Use new MemorySize(MemoryManager.MIN_PAGE_SIZE) so the configured value stays at the enforced floor, preserving the original intent of keeping buffers small while staying above the validated minimum. --- .../UnalignedCheckpointRescaleWithMixedExchangesITCase.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointRescaleWithMixedExchangesITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointRescaleWithMixedExchangesITCase.java index d9061ae3f05..9664e109e84 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointRescaleWithMixedExchangesITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointRescaleWithMixedExchangesITCase.java @@ -33,6 +33,7 @@ import org.apache.flink.configuration.StateRecoveryOptions; import org.apache.flink.configuration.TaskManagerOptions; import org.apache.flink.connector.datagen.source.DataGeneratorSource; import org.apache.flink.core.execution.JobClient; +import org.apache.flink.runtime.memory.MemoryManager; import org.apache.flink.runtime.minicluster.MiniCluster; import org.apache.flink.runtime.testutils.CommonTestUtils; import org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration; @@ -180,7 +181,9 @@ class UnalignedCheckpointRescaleWithMixedExchangesITCase { // enabled. All buffers(records) before barrier must be consumed for aligned checkpoint. // The smaller the buffer size means the fewer records are needed to be consumed during // aligned checkpoint. - conf.set(TaskManagerOptions.MEMORY_SEGMENT_SIZE, MemorySize.parse("1 kb")); + conf.set( + TaskManagerOptions.MEMORY_SEGMENT_SIZE, + new MemorySize(MemoryManager.MIN_PAGE_SIZE)); if (recoveryPath != null) { conf.set(StateRecoveryOptions.SAVEPOINT_PATH, recoveryPath); }
