Dawid Wysakowicz created FLINK-38765:
----------------------------------------
Summary: Sink Upsert Materializer does not work with metadata
columns
Key: FLINK-38765
URL: https://issues.apache.org/jira/browse/FLINK-38765
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Reporter: Dawid Wysakowicz
Assignee: Dawid Wysakowicz
Fix For: 1.19.4, 2.1.2, 2.0.2, 2.3.0
We use an incorrect type in
https://github.com/apache/flink/blob/d0ab038ecbb2ebf64ba7f5e673a6c5bb8b8360fe/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSink.java#L154
where we strip all metadata columns
That means:
# Sink Upsert Materializer may produce shorter records (without metadata
columns) - when retracting to a previous value, retrieved from state
# Sink Upsert Materializer does not use metadata columns for equality comparison
# Partitioning may not use the correct key columns, if the key columns are
defineed after the metadata columns
# Constraint validation is not applied for persisted metadata columns
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
