flink-cdc icon indicating copy to clipboard operation
flink-cdc copied to clipboard

Published 20 hours ago • verified publisher icon apache

[FLINK-36541][pipeline-connector][paimon] pass checkpointId to StoreSinkWrite#prepareCommit correctly.

Open lvyanquan opened this issue 4 months ago • 0 comments

PaimonSink now implements StatefulSink to store checkpointId in state, It has been verified through local testing that it is compatible with the state of 3.2.0. I will try to add a state compatibility test.

lvyanquan avatar Oct 18 '24 07:10 lvyanquan