[ https://issues.apache.org/jira/browse/FLINK-29554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jingsong Lee closed FLINK-29554. -------------------------------- Resolution: Fixed master: 8e63f1f67fcfe83773a7264068687c7340bc01cb > 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 > Assignee: Jingsong Lee > Priority: Major > Labels: pull-request-available > Fix For: table-store-0.3.0 > > > 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)