[jira] [Updated] (FLINK-29554) Add partial-update.ignore-delete option to avoid exception after join
[ https://issues.apache.org/jira/browse/FLINK-29554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29554: - Fix Version/s: (was: table-store-0.2.2) > 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)
[jira] [Updated] (FLINK-29554) Add partial-update.ignore-delete option to avoid exception after join
[ https://issues.apache.org/jira/browse/FLINK-29554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29554: - Fix Version/s: table-store-0.2.2 > 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, table-store-0.2.2 > > > 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)
[jira] [Updated] (FLINK-29554) Add partial-update.ignore-delete option to avoid exception after join
[ https://issues.apache.org/jira/browse/FLINK-29554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29554: - Fix Version/s: (was: table-store-0.2.1) > 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)
[jira] [Updated] (FLINK-29554) Add partial-update.ignore-delete option to avoid exception after join
[ https://issues.apache.org/jira/browse/FLINK-29554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29554: --- Labels: pull-request-available (was: ) > 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, 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)
