Skip to content

Commit f3ed283

Browse files
committed
[FLINK-36790][cdc-connector][paimon] set waitCompaction with true during prepare common of PaimonWriter to avoid CME problem
1 parent c969957 commit f3ed283

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonWriter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,7 @@ public Collection<MultiTableCommittable> prepareCommit() throws IOException {
9696
for (Map.Entry<Identifier, StoreSinkWrite> entry : writes.entrySet()) {
9797
Identifier key = entry.getKey();
9898
StoreSinkWrite write = entry.getValue();
99-
boolean waitCompaction = false;
99+
boolean waitCompaction = true;
100100
committables.addAll(
101101
// here we set it to lastCheckpointId+1 to
102102
// avoid prepareCommit the same checkpointId with the first round.

0 commit comments

Comments
 (0)