Details
-
Sub-task
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
Description
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.
Attachments
Issue Links
- relates to
-
FLINK-20374 Wrong result when shuffling changelog stream on non-primary-key columns
- Closed
- links to