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<String, FileStoreTable> 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()) {
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) {