[ https://issues.apache.org/jira/browse/FLINK-19072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Leonard Xu updated FLINK-19072: ------------------------------- Description: The initial temporal table join (FOR SYSTEM_TIME AS OF) is a Correlate, we need rewrite it into a Join to make join condition can be pushed-down. The join will be translated into [[StreamExecLookupJoin]] or [[StreamExecTemporalJoin]] in physical. Import Temporal table join rule to deal above temporal join rewrite logic. > Import Temporal Table join rule > ------------------------------- > > Key: FLINK-19072 > URL: https://issues.apache.org/jira/browse/FLINK-19072 > Project: Flink > Issue Type: Sub-task > Reporter: Leonard Xu > Priority: Major > > The initial temporal table join (FOR SYSTEM_TIME AS OF) is a Correlate, we > need rewrite it into a Join to make join condition can be pushed-down. The > join will be translated into [[StreamExecLookupJoin]] or > [[StreamExecTemporalJoin]] in physical. > Import Temporal table join rule to deal above temporal join rewrite logic. -- This message was sent by Atlassian Jira (v8.3.4#803005)