[jira] [Created] (FLINK-29554) Add partial-update.ignore-delete option to avoid exception after join

["Jingsong Lee (Jira)" <ji...@apache.org>]

Jingsong Lee created FLINK-29554:
------------------------------------

             Summary: Add partial-update.ignore-delete option to avoid exception after join
                 Key: FLINK-29554
                 URL: https://issues.apache.org/jira/browse/FLINK-29554
             Project: Flink
          Issue Type: Improvement
          Components: Table Store
            Reporter: Jingsong Lee
             Fix For: table-store-0.3.0, table-store-0.2.1


When the partial update input is a normal database cdc input, it can work normally as long as there is no delete data.
However, if a join is performed previously, the join node in flink job will generate delete messages, which will cause the partial update insertion to throw an exception.
We can add an option to decide whether to ignore the delete message in this case.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)