Martijn Visser created FLINK-40900:
--------------------------------------
Summary: NDU analyzer does not check predicates pushed into a CDC
source
Key: FLINK-40900
URL: https://issues.apache.org/jira/browse/FLINK-40900
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Reporter: Martijn Visser
{{visitTableSourceScan}} in {{StreamNonDeterministicUpdatePlanVisitor}} only
checks metadata columns. A predicate that a source with updates accepts through
{{SupportsFilterPushDown}} is evaluated by the source for inserts and
retractions alike and never reaches the visitor, so a non-deterministic one has
the same effect as the Calc case in FLINK-28737 without being reported. We
should check whether the push-down rules already keep non-deterministic
predicates out of updating sources, and if not either check them in the visitor
or stop pushing them.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
