[jira] [Closed] (FLINK-23054) Correct upsert optimization by upsert keys
[ https://issues.apache.org/jira/browse/FLINK-23054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-23054. Resolution: Fixed release-1.13: 2c546e85e922e28f21b2972392622ea2ca30b5cd 68451e9268d32c6110bf5b844a4eee5dc4248066 bf4d675ef2a7a31413f00a58d710c4b74718457e fe19395f62a98d2368e49753b109f0f02363066b > Correct upsert optimization by upsert keys > -- > > Key: FLINK-23054 > URL: https://issues.apache.org/jira/browse/FLINK-23054 > Project: Flink > Issue Type: Sub-task > Components: Table SQL / Runtime >Reporter: Jingsong Lee >Assignee: Jingsong Lee >Priority: Major > Labels: pull-request-available > Fix For: 1.14.0 > > > After FLINK-22901. > We can use upsert keys to fix upsert join, upsert rank, and upsert sink. > * For join and rank: if input has no upsert keys, do not use upsert > optimization. > * For upsert sink: if input has unique keys but no upsert keys, we need add > a materialize operator to produce upsert records. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-23054) Correct upsert optimization by upsert keys
[ https://issues.apache.org/jira/browse/FLINK-23054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-23054. Resolution: Fixed Fixed via (master): e1117f0897cee184622bf5cce772c869d95afb7e 4642c1f47f40637d82225a259e3fa474a78a8586 992340edabc118480464e962a7a9f3a0752e24a1 5fdc01e3a58540d4bc89c9f291cafd31d24f37d3 > Correct upsert optimization by upsert keys > -- > > Key: FLINK-23054 > URL: https://issues.apache.org/jira/browse/FLINK-23054 > Project: Flink > Issue Type: Bug > Components: Table SQL / Runtime >Reporter: Jingsong Lee >Assignee: Jingsong Lee >Priority: Major > Labels: pull-request-available > Fix For: 1.14.0 > > > After FLINK-22901. > We can use upsert keys to fix upsert join, upsert rank, and upsert sink. > * For join and rank: if input has no upsert keys, do not use upsert > optimization. > * For upsert sink: if input has unique keys but no upsert keys, we need add > a materialize operator to produce upsert records. -- This message was sent by Atlassian Jira (v8.3.4#803005)
