Skip to content

Commit 148bb5f

Browse files
committed
feat: improve paimon table param
1 parent 98975a3 commit 148bb5f

File tree

1 file changed

+3
-4
lines changed
  • connectors/paimon-connector/src/main/java/io/tapdata/connector/paimon/service

1 file changed

+3
-4
lines changed

connectors/paimon-connector/src/main/java/io/tapdata/connector/paimon/service/PaimonService.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -587,18 +587,17 @@ public boolean createTable(TapTable tapTable, Log log) throws Exception {
587587
if (config.getEnableAutoCompaction(tableName) != null) {
588588
if (config.getEnableAutoCompaction(tableName)) {
589589
// Enable full compaction for better query performance
590-
schemaBuilder.option("compaction.async.enabled", "true");
591590
schemaBuilder.option("compaction.optimization-interval", config.getCompactionIntervalMinutes(tableName) + "min");
592591

593592
// Set compaction strategy
594593
schemaBuilder.option("changelog-producer", "input");
595594

596595
// Compact small files more aggressively
597-
schemaBuilder.option("num-sorted-run.compaction-trigger", "3");
598-
schemaBuilder.option("num-sorted-run.stop-trigger", "5");
596+
schemaBuilder.option("num-sorted-run.compaction-trigger", "30");
597+
schemaBuilder.option("num-sorted-run.stop-trigger", "2147483647");
599598
} else {
600599
// Disable auto compaction
601-
schemaBuilder.option("compaction.optimization-interval", "0");
600+
schemaBuilder.option("write-only", "true");
602601
}
603602
}
604603

0 commit comments

Comments
 (0)