We don't support 'PROCTIME()' in a temporal table join. Please use a left table's proctime field. [1]
[1] https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/streaming/joins.html#usage-1 *Best Regards,* *Zhenghua Gao* On Fri, Mar 13, 2020 at 11:57 AM wangl...@geekplus.com.cn < wangl...@geekplus.com.cn> wrote: > > Kafka source table: > > CREATE TABLE out_order ( > out_order_code VARCHAR, > intput_date BIGINT, > owner_code VARCHAR > ) WITH ( > 'connector.type' = 'kafka', > > MySQL dimention table: > > CREATE TABLE dim_owner ( > owner_code VARCHAR, > owner_name VARCHAR > ) WITH ( > 'connector.type' = 'jdbc', > > When i submit the sql: SELECT o.out_order_code, o.input_date, o.owner_code, > d.owner_name FROM out_order as o > > JOIN dim_owner FOR SYSTEM_TIME AS OF PROCTIME() as d > ON o.owner_code = d.owner_code; > > There's error: > [ERROR] Could not execute SQL statement. Reason: > org.apache.flink.table.api.TableException: Temporal table join currently > only supports 'FOR SYSTEM_TIME AS OF' left table's proctime field, doesn't > support 'PROCTIME()' > > Thanks, > Lei > > ------------------------------ > wangl...@geekplus.com.cn > >
