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 

Reply via email to