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