You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Jark Wu (Jira)" <ji...@apache.org> on 2020/01/03 02:03:00 UTC
[jira] [Resolved] (FLINK-14613) Add validation check when applying
UDF to tempral table key in Temporal Table Join condition
[ https://issues.apache.org/jira/browse/FLINK-14613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jark Wu resolved FLINK-14613.
-----------------------------
Resolution: Fixed
1.11.0: 9637af38b415e08888e45dde06a220507c4f53ae
1.10.0: 33cd82238cdd0a590aa83a8b9afcdb4f639da5d6
> 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: Bug
> Components: Table SQL / Planner
> Reporter: hailong wang
> Assignee: hailong wang
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.10.0
>
> Time Spent: 20m
> Remaining Estimate: 0h
>
> 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)