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
[email protected]