[
https://issues.apache.org/jira/browse/FLINK-39636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-39636:
-----------------------------------
Labels: pull-request-available (was: )
> Add "produces_full_deletes" parameter in TO_CHANGELOG
> -----------------------------------------------------
>
> Key: FLINK-39636
> URL: https://issues.apache.org/jira/browse/FLINK-39636
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / API
> Reporter: Gustavo de Morais
> Priority: Major
> Labels: pull-request-available
>
> We currently always require full deletes in TO_CHANGELOG by using the PTF
> trait "StaticArgumentTrait.REQUIRE_FULL_DELETE". That means, if we have a
> source containing partial deletes (as kafka does) we'll add a
> ChangelogNormalize to the pipeline to build full delete events out of partial
> deletes.
> By adding the produces_full_deletes param, we can make this trait conditional
> and check and only require full deletes if we have to produce full deletes.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
