This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch release-0.8 in repository https://gitbox.apache.org/repos/asf/paimon.git
commit b1944274e4ecab1b1c4143566f3bbd0c86d19c79 Author: YeJunHao <[email protected]> AuthorDate: Wed May 15 18:29:55 2024 +0800 [flink] Respect waitCompaction in FlinkCdcMultiTableSink (#3337) --- .../java/org/apache/paimon/flink/sink/cdc/FlinkCdcMultiTableSink.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcMultiTableSink.java b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcMultiTableSink.java index cff31087b..4254cb6b0 100644 --- a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcMultiTableSink.java +++ b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/FlinkCdcMultiTableSink.java @@ -19,6 +19,7 @@ package org.apache.paimon.flink.sink.cdc; import org.apache.paimon.catalog.Catalog; +import org.apache.paimon.flink.FlinkConnectorOptions; import org.apache.paimon.flink.VersionedSerializerWrapper; import org.apache.paimon.flink.sink.CommittableStateManager; import org.apache.paimon.flink.sink.Committer; @@ -83,7 +84,8 @@ public class FlinkCdcMultiTableSink implements Serializable { state, ioManager, isOverwrite, - false, + FlinkConnectorOptions.prepareCommitWaitCompaction( + table.coreOptions().toConfiguration()), true, memoryPoolFactory, metricGroup);
