Yanquan Lv created FLINK-37352:
----------------------------------
Summary: Write full changelog to Paimon Sink.
Key: FLINK-37352
URL: https://issues.apache.org/jira/browse/FLINK-37352
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Affects Versions: cdc-3.3.0
Reporter: Yanquan Lv
Fix For: cdc-3.4.0
Paimon streaming write can continuously produce the latest changes for
streaming read.
By specifying {{{}'changelog-producer' = 'input'{}}}, Paimon writers rely on
their inputs as a source of complete changelog. All input records will be saved
in separated changelog files and will be given to the consumers by Paimon
sources.
However, currently we have only inserted the update after data for Update, so
the generated changelog is incomplete.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
