[
https://issues.apache.org/jira/browse/FLINK-37475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-37475.
------------------------------------
Resolution: Implemented
Implemented in 50d46e11bd37ea3f2c19dd8f9a77c2b2dad4b7aa
> Drop ChangelogNormalize for piping from upsert source to sink
> -------------------------------------------------------------
>
> Key: FLINK-37475
> URL: https://issues.apache.org/jira/browse/FLINK-37475
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / API, Table SQL / Planner
> Reporter: Dawid Wysakowicz
> Assignee: Dawid Wysakowicz
> Priority: Major
> Labels: pull-request-available
> Fix For: 2.1.0
>
>
> This task is about introducing the interfaces in FLIP-510. Moreover as part
> of the task we should implement the removal of ChangelogNormalize for a query
> like
> {code}
> INSERT INTO sink SELECT * FROM source
> {code}
> where the source produces I, UA, D (with key only)
> and the sink accepts I, UA, D (with key only)
> This is a.k.a Upsert Kafka case
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
