[
https://issues.apache.org/jira/browse/FLINK-37327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928458#comment-17928458
]
David Radley commented on FLINK-37327:
--------------------------------------
Thanks for the explanation [~klam-shop] that makes a lot more sense.
> 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
> Priority: Minor
> Labels: pull-request-available
>
> 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)
