Timo Walther created FLINK-33182:
------------------------------------
Summary: Allow metadata columns in NduAnalyzer with
ChangelogNormalize
Key: FLINK-33182
URL: https://issues.apache.org/jira/browse/FLINK-33182
Project: Flink
Issue Type: Sub-task
Components: Table SQL / Planner
Reporter: Timo Walther
Currently, the NduAnalyzer is very strict about metadata columns in updating
sources. However, for upsert sources (like Kafka) that contain an incomplete
changelog, the planner always adds a ChangelogNormalize node.
ChangelogNormalize will make sure that metadata columns can be considered
deterministic. So the NduAnalyzer should be satisfied in this case.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
