Update seatunnel-connectors-v2/connector-databend/src/main/java/org/apache/seatunnel/connectors/seatunnel/databend/sink/DatabendSinkAggregatedCommitter.java

hantmac · Hisoka-X · web-flow · commit b733b1442bb9 · 2025-08-21T15:59:40.000+08:00
Co-authored-by: Jia Fan &lt;fanjiaeminem@qq.com&gt;
diff --git a/seatunnel-connectors-v2/connector-databend/src/main/java/org/apache/seatunnel/connectors/seatunnel/databend/sink/DatabendSinkAggregatedCommitter.java b/seatunnel-connectors-v2/connector-databend/src/main/java/org/apache/seatunnel/connectors/seatunnel/databend/sink/DatabendSinkAggregatedCommitter.java
@@ -129,7 +129,7 @@ private String getCurrentTimestamp() {
     public List<DatabendSinkAggregatedCommitInfo> commit(
             List<DatabendSinkAggregatedCommitInfo> aggregatedCommitInfos) throws IOException {
         // Perform final merge operation in CDC mode only when necessary
-        if (isCdcMode && shouldPerformMerge()) {
+        if (isCdcMode) {
             performMerge(aggregatedCommitInfos);
         }
 

Original file line number	Diff line number	Diff line change
`@@ -129,7 +129,7 @@ private String getCurrentTimestamp() {`
`129`	`129`	`public List<DatabendSinkAggregatedCommitInfo> commit(`
`130`	`130`	`List<DatabendSinkAggregatedCommitInfo> aggregatedCommitInfos) throws IOException {`
`131`	`131`	`// Perform final merge operation in CDC mode only when necessary`
`132`		`- if (isCdcMode && shouldPerformMerge()) {`
	`132`	`+ if (isCdcMode) {`
`133`	`133`	`performMerge(aggregatedCommitInfos);`
`134`	`134`	`}`
`135`	`135`