Gustavo de Morais created FLINK-41472:
-----------------------------------------
Summary: Support updating input in DEDUPLICATE
Key: FLINK-41472
URL: https://issues.apache.org/jira/browse/FLINK-41472
Project: Flink
Issue Type: Sub-task
Components: Table SQL / Planner, Table SQL / Runtime
Reporter: Gustavo de Morais
Assignee: Vas Shabu
Accept updating input when the PARTITION BY columns contain an upsert key of
the input, and reject it at planning time otherwise. Handle upsert and retract
messages: -D clears the key and is emitted, and -U/-D for a key without state
are ignored.
--
This message was sent by Atlassian Jira
(v10.3.26#10030026)
