[
https://issues.apache.org/jira/browse/FLINK-24717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-24717.
--------------------------------
Release Note: This might have an impact on existing table source
implementations as push down filters might not contain partition predicates
anymore. However, the connector implementation for table sources that implement
both partition and filter push down became easier with this change.
Resolution: Fixed
Fixed in master: 8829e23279dd17965f2f86aa79dbf8814900de94
> Push down partitions before filters
> -----------------------------------
>
> Key: FLINK-24717
> URL: https://issues.apache.org/jira/browse/FLINK-24717
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / Planner
> Reporter: Timo Walther
> Assignee: xuyang
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.15.0
>
>
> Currently, we push filters before partitions. This means that a
> {{applyFilters}} needs to have partition logic to extract the partition
> predicate. Furthermore, if a {{applyFilters}} consumes all filters (no
> remaining predicates), the {{applyPartitions}} is never called.
> We should execute the {{PushPartitionIntoTableSourceScanRule}} first and
> check for side effects of this change.
> See
> {{org.apache.flink.table.planner.plan.rules.logical.PushProjectIntoTableSourceScanRuleTest#testMetadataProjectionWithoutProjectionPushDownWhenNotSupportedAndNoneSelected}}
> for an example of using the new test infrastructure.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
