You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Gen Luo (Jira)" <ji...@apache.org> on 2022/08/08 09:06:00 UTC

[jira] [Created] (FLINK-28864) DynamicPartitionPruningRule#isNewSource should check if the source used by the DataStreamScanProvider is actually a new sourc

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)