[FLINK-36790][cdc-connector][paimon] set waitCompaction with true dur…

…ing prepare common of PaimonWriter to avoid CME problem
apache · Nov 26, 2024 · f3ed283 · f3ed283
1 parent c969957
commit f3ed283
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...tor-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonWriter.java b/...tor-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonWriter.java
@@ -96,7 +96,7 @@ public Collection<MultiTableCommittable> prepareCommit() throws IOException {
         for (Map.Entry<Identifier, StoreSinkWrite> entry : writes.entrySet()) {
             Identifier key = entry.getKey();
             StoreSinkWrite write = entry.getValue();
-            boolean waitCompaction = false;
+            boolean waitCompaction = true;
             committables.addAll(
                     // here we set it to lastCheckpointId+1 to
                     // avoid prepareCommit the same checkpointId with the first round.