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<>(); 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()) {