Dawid Wysakowicz created FLINK-37477:
----------------------------------------
Summary: Drop ChangelogNormalize for a StreamJoin
Key: FLINK-37477
URL: https://issues.apache.org/jira/browse/FLINK-37477
Project: Flink
Issue Type: Sub-task
Components: Table SQL / Planner
Reporter: Dawid Wysakowicz
Assignee: Dawid Wysakowicz
Fix For: 2.1.0
StreamExecJoin can consume deletes on key if the join conditions is on primary
keys. The state lookups happen using the key. However for deletes it uses the
currently incoming record, which in case of DELETE may be a DELETE on key.
Given that we have the information about previous value, we can emit the full
delete instead. This will make JOIN operator work similarly like
ChangelogNormalize.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
