Gen Luo created FLINK-28864:
-------------------------------
Summary: DynamicPartitionPruningRule#isNewSource should check if
the source used by the DataStreamScanProvider is actually a new sourc
Key: FLINK-28864
URL: https://issues.apache.org/jira/browse/FLINK-28864
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Reporter: Gen Luo
DynamicPartitionPruningRule#isNewSource supposes DataStreamScanProvider that
supports dynamic filtering will use new source as its source, but it's not
reliable. For better compatibility, the method should acquire the source
transformation from the translated DataStream and check if the source is
actually a new source.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
