[
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)
