Kevin Lam created FLINK-37327:
---------------------------------
Summary: Debezium Avro Format: Add FormatOption to Optionally Skip
emitting UPDATE_BEFORE Rows
Key: FLINK-37327
URL: https://issues.apache.org/jira/browse/FLINK-37327
Project: Flink
Issue Type: Improvement
Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
Affects Versions: 1.20.1
Reporter: Kevin Lam
Add a Format Option to the Debezium Format to optionally skip emitting the
UPDATE_BEFORE Rows when deserializing a Debezium message with op='u'.
This is helpful for Flink SQL applications that want to operate in UPSERT
(ChangelogMode=[I,UA,D]) mode and save on processing the UPDATE_BEFORE Rows
since the downstream sinks can handle it.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
