[ https://issues.apache.org/jira/browse/FLINK-14613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968164#comment-16968164 ]
hailong wang commented on FLINK-14613: -------------------------------------- Hi [~jark], I sorry for giving a wrong example. I have updated. In short, when using UDF in tempral table join key, the result is error. For the join condition is still B.amount = C.amount, but not B.amount = cancat(C.amount, 'r') .So when used like this, we should throw error when validation? > 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 > Priority: Major > 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 = cancat(C.amount, 'r') and C.product = '1' > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)