[jira] [Created] (FLINK-14613) Add validation check when applying UDF to tempral table key in Temporal Table Join condition

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-14613) Add validation check when applying UDF to tempral table key in Temporal Table Join condition

Shang Yuanchun (Jira)
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)