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)
