Dawid Wysakowicz created FLINK-37475:
----------------------------------------
Summary: 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
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)
