Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
1.12.0
Description
sql 1: |SELECT T.*, D.id |FROM MyTable AS T |JOIN LookupTable FOR SYSTEM_TIME AS OF T.proctime AS D |ON T.a = D.id optmized plan: Calc(select=[a, b, c, PROCTIME_MATERIALIZE(proctime) AS proctime, rowtime, id]) +- LookupJoin(table=[default_catalog.default_database.LookupTable], joinType=[InnerJoin], async=[false], lookup=[id=a], select=[a, b, c, proctime, rowtime, id, name, age]) +- DataStreamScan(table=[[default_catalog, default_database, MyTable]], fields=[a, b, c, proctime, rowtime]) sql 2: |SELECT T.a, D.id |FROM MyTable AS T |JOIN LookupTable FOR SYSTEM_TIME AS OF T.proctime AS D |ON T.a = D.id optmized plan: LookupJoin(table=[default_catalog.default_database.LookupTable], joinType=[InnerJoin], async=[false], lookup=[id=a], select=[a, id]) +- Calc(select=[a]) +- DataStreamScan(table=[[default_catalog, default_database, MyTable]], fields=[a, b, c, proctime, rowtime])
Attachments
Issue Links
- is related to
-
FLINK-18778 Support the SupportsProjectionPushDown interface for LookupTableSource
- Closed
-
FLINK-29138 Project pushdown not work for lookup source
- Closed
- links to