We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b0e4ed9 commit c4b904bCopy full SHA for c4b904b
1 file changed
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactDatabaseAction.java
@@ -64,7 +64,7 @@ public class CompactDatabaseAction extends ActionBase {
64
@Nullable private Pattern excludingPattern;
65
private Pattern databasePattern = Pattern.compile(".*");
66
67
- private MultiTablesSinkMode databaseCompactMode = MultiTablesSinkMode.DIVIDED;
+ private MultiTablesSinkMode databaseCompactMode = MultiTablesSinkMode.COMBINED;
68
69
private final Map<String, FileStoreTable> tableMap = new HashMap<>();
70
0 commit comments