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 ffd01f74c6d053545b9852b23f0e3f8c97ae8b60 Author: Rui Fan <[email protected]> AuthorDate: Thu Feb 26 14:42:57 2026 +0100 [FLINK-39140][test] Disable CUSTOM_PARTITIONER in unaligned checkpoint it case since it does not work well See FLINK-39162 --- .../flink/test/checkpointing/UnalignedCheckpointRescaleITCase.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointRescaleITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointRescaleITCase.java index 5be756a0efa..f8332472741 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointRescaleITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointRescaleITCase.java @@ -549,7 +549,8 @@ public class UnalignedCheckpointRescaleITCase extends UnalignedCheckpointTestBas // captured in-flight records, see FLINK-31963. Object[][] parameters = new Object[][] { - new Object[] {"downscale", Topology.CUSTOM_PARTITIONER, 3, 2, 0L}, + // Disable CUSTOM_PARTITIONER since it does not work well, see FLINK-39162 + // new Object[] {"downscale", Topology.CUSTOM_PARTITIONER, 3, 2, 0L}, new Object[] {"downscale", Topology.KEYED_DIFFERENT_PARALLELISM, 12, 7, 0L}, new Object[] {"upscale", Topology.KEYED_DIFFERENT_PARALLELISM, 7, 12, 0L}, new Object[] {"downscale", Topology.KEYED_DIFFERENT_PARALLELISM, 5, 3, 5L},
