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/08/17 04:05:00 UTC
[jira] [Assigned] (FLINK-18212) Init lookup join failed when use
udf on lookup table
[ https://issues.apache.org/jira/browse/FLINK-18212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jark Wu reassigned FLINK-18212:
-------------------------------
Assignee: Jark Wu
> Init lookup join failed when use udf on lookup table
> ----------------------------------------------------
>
> Key: FLINK-18212
> URL: https://issues.apache.org/jira/browse/FLINK-18212
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Planner
> Affects Versions: 1.10.1
> Reporter: YufeiLiu
> Assignee: Jark Wu
> Priority: Major
>
> Throw exception
> {code}
> Caused by: scala.MatchError: (CONCAT(_UTF-16LE'Hello', $2),_UTF-16LE'Hello,Jark':VARCHAR(2147483647) CHARACTER SET "UTF-16LE") (of class scala.Tuple2)
> at org.apache.flink.table.planner.plan.nodes.common.CommonLookupJoin.org$apache$flink$table$planner$plan$nodes$common$CommonLookupJoin$$extractConstantField(CommonLookupJoin.scala:617)
> at org.apache.flink.table.planner.plan.nodes.common.CommonLookupJoin.extractConstantFieldsFromEquiCondition(CommonLookupJoin.scala:607)
> at org.apache.flink.table.planner.plan.nodes.common.CommonLookupJoin.analyzeLookupKeys(CommonLookupJoin.scala:567)
> at org.apache.flink.table.planner.plan.nodes.common.CommonLookupJoin.<init>(CommonLookupJoin.scala:129)
> at org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecLookupJoin.<init>(StreamExecLookupJoin.scala:49)
> {code}
> SQL:
> {code:sql}
> SELECT
> T.id, T.len, T.content, D.name
> FROM
> T JOIN userTable for system_time as of T.proctime AS D
> ON T.id = D.id
> WHERE
> add(T.id, D.id) > 3 AND add(T.id, 2) > 3 AND CONCAT('Hello', D.name) = 'Hello,Jark'
> {code}
> When use function a RexCall can't match RexInputRef and cause this error, myabe shoud add condition"{{case _ => return}}" to skip this.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)