Jingsong Lee created FLINK-25183: ------------------------------------ Summary: Optimize changelog normalize for the managed table upsert mode Key: FLINK-25183 URL: https://issues.apache.org/jira/browse/FLINK-25183 Project: Flink Issue Type: Sub-task Reporter: Jingsong Lee Fix For: 1.15.0
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. -- This message was sent by Atlassian Jira (v8.20.1#820001)