You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/12/06 08:32:00 UTC

[jira] [Created] (FLINK-25183) Optimize changelog normalize for the managed table upsert mode

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)