From 7eb469dc46993c8195c0c41f58b2c55fe401a7fd Mon Sep 17 00:00:00 2001 From: peiyu <125331682@qq.com> Date: Tue, 6 Jan 2026 10:52:02 +0800 Subject: [PATCH 1/2] 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 ec528005192442c8e6109fca22807577ca5038d8 Mon Sep 17 00:00:00 2001 From: peiyu <125331682@qq.com> Date: Wed, 7 Jan 2026 20:08:04 +0800 Subject: [PATCH 2/2] 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()) {