flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "wanglei2@geekplus.com.cn" <wangl...@geekplus.com.cn>
Subject dimention table join not work under sql-client fink-1.10.0
Date Fri, 13 Mar 2020 03:56:51 GMT

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



wanglei2@geekplus.com.cn 

Mime
View raw message