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)