From 4f184d632037cd5ca51ad5ea062161a6a890b65c Mon Sep 17 00:00:00 2001 From: peiyu <125331682@qq.com> Date: Tue, 6 Jan 2026 10:52:02 +0800 Subject: [PATCH 1/3] fix compact_database parameter mode default value Signed-off-by: peiyu <125331682@qq.com> --- .../org/apache/paimon/flink/action/CompactDatabaseAction.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactDatabaseAction.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactDatabaseAction.java index 1a65b8d1bd60..de661bfd582b 100644 --- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactDatabaseAction.java +++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactDatabaseAction.java @@ -64,7 +64,7 @@ public class CompactDatabaseAction extends ActionBase { @Nullable private Pattern excludingPattern; private Pattern databasePattern = Pattern.compile(".*"); - private MultiTablesSinkMode databaseCompactMode = MultiTablesSinkMode.DIVIDED; + private MultiTablesSinkMode databaseCompactMode = MultiTablesSinkMode.COMBINED; private final Map tableMap = new HashMap<>(); From a1cfc4407c69dcc4a58e3c7847cb8e3dd677dd5b Mon Sep 17 00:00:00 2001 From: peiyu <125331682@qq.com> Date: Wed, 7 Jan 2026 20:08:04 +0800 Subject: [PATCH 2/3] fix compact_database parameter mode default value Signed-off-by: peiyu <125331682@qq.com> --- .../org/apache/paimon/flink/action/MultiTablesSinkMode.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MultiTablesSinkMode.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MultiTablesSinkMode.java index d5c514199589..cfba932e3601 100644 --- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MultiTablesSinkMode.java +++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MultiTablesSinkMode.java @@ -37,7 +37,7 @@ public enum MultiTablesSinkMode implements Serializable { public static MultiTablesSinkMode fromString(@Nullable String mode) { if (mode == null) { - return DIVIDED; + return COMBINED; } switch (mode.toLowerCase()) { From 8a5d099cfe83e7fc788decd034e554784c77e7f1 Mon Sep 17 00:00:00 2001 From: peiyu <125331682@qq.com> Date: Thu, 22 Jan 2026 11:15:38 +0800 Subject: [PATCH 3/3] fix compact_database ut mode value Signed-off-by: peiyu <125331682@qq.com> --- .../paimon/flink/action/CompactDatabaseActionITCase.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CompactDatabaseActionITCase.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CompactDatabaseActionITCase.java index acb0267440d7..a5ef5efc5cf2 100644 --- a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CompactDatabaseActionITCase.java +++ b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CompactDatabaseActionITCase.java @@ -907,12 +907,15 @@ public void testUnawareBucketStreamingCompact() throws Exception { if (ThreadLocalRandom.current().nextBoolean()) { StreamExecutionEnvironment env = streamExecutionEnvironmentBuilder().streamingMode().build(); - createAction(CompactDatabaseAction.class, "compact_database", "--warehouse", warehouse) + createAction(CompactDatabaseAction.class, + "compact_database", + "--warehouse", warehouse, + "--mode", "divided") .withStreamExecutionEnvironment(env) .build(); env.executeAsync(); } else { - executeSQL("CALL sys.compact_database()"); + executeSQL("CALL sys.compact_database(mode => 'divided')"); } for (FileStoreTable table : tables) {