hailong wang created FLINK-14613:
------------------------------------
Summary: Add validation check when applying UDF to tempral table key in Temporal Table Join condition
Key: FLINK-14613
URL:
https://issues.apache.org/jira/browse/FLINK-14613 Project: Flink
Issue Type: Improvement
Components: Table SQL / Planner
Affects Versions: 1.9.1
Reporter: hailong wang
Fix For: 1.10.0
In Temporal Table Join, We don't support using UDF in tempral table join key. For we can't analyze LookupKeys when call is an expression. When users use like this, the program run normally, and the result will be wrong. So we should add validation to prevent it.
The SQL as following:
{code:java}
INSERT INTO A
SELECT B.amount, B.currency, C.amount, C.product
FROM B join C FOR SYSTEM_TIME AS OF B.proctime
on B.amount = C.amount and C.product = '1'
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)