[FLINK-25183] Optimize changelog normalize for the managed table upsert mode

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.15.0
• Labels: pull-request-available
• Assignee: Lsw_aka_laplace
• Reporter: Jingsong Lee
• Created: 06/Dec/21 08:31
• Updated: 02/Mar/22 08:34
• Resolved: 05/Jan/22 01:51

Description

The upsert mode of managed table preserves the complete delete message and avoids normalization for the following downstream operators:

• Upsert sink: Upsert sink only requires upsert inputs without UPDATE_BEFORE.
• Join: Join for unique inputs will store records by unique key. It can work without  UPDATE_BEFORE.

Issue Links

• links to: GitHub Pull Request #18199