[
https://issues.apache.org/jira/browse/FLINK-38634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuyang Zhong updated FLINK-38634:
---------------------------------
Attachment: image-2025-11-05-14-16-16-296.png
> The filter on the dim table will not be pushed down
> ---------------------------------------------------
>
> Key: FLINK-38634
> URL: https://issues.apache.org/jira/browse/FLINK-38634
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / Planner
> Affects Versions: 2.0.1, 2.1.1
> Reporter: Xuyang Zhong
> Assignee: Xuyang Zhong
> Priority: Major
> Attachments: image-2025-11-05-14-16-16-296.png
>
>
> Take the following test as example:
>
> {code:java}
> // batch CalcTest
> @Test
> def test(): Unit = {
> val tEnv = util.tableEnv
> tEnv.executeSql("""
> |create table src(
> | a int,
> | b int,
> | pt as proctime()
> |) with (
> | 'connector' = 'values',
> | 'bounded' = 'true'
> |)
> |""".stripMargin)
> tEnv.executeSql("""
> |create table dim(
> | a int,
> | b int
> |) with (
> | 'connector' = 'values',
> | 'filterable-fields' = 'b',
> | 'bounded' = 'true'
> |)
> |""".stripMargin)
> util.verifyRelPlan(
> """
> |select src.* from src join dim for system_time as of src.pt on src.a =
> dim.a and dim.b = 1
> |""".stripMargin)
> } {code}
>
> after CalcSnapshotTransposeRule, we lack
> PushFilterInCalcIntoTableSourceScanRule to push down filter in the calc to
> source.
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
