[
https://issues.apache.org/jira/browse/FLINK-26540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Zhang closed FLINK-26540.
------------------------------
Resolution: Fixed
> Support handle join involving complex types in on condition
> -----------------------------------------------------------
>
> Key: FLINK-26540
> URL: https://issues.apache.org/jira/browse/FLINK-26540
> Project: Flink
> Issue Type: Sub-task
> Components: Connectors / Hive
> Reporter: luoyuxia
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.16.0
>
>
> Now, the Hive dialect can't handle join involving complex types in on
> condition, which can be reproduced using the following code in
> HiveDialectITCase:
> {code:java}
> tableEnv.executeSql("CREATE TABLE test2a (a ARRAY<INT>)");
> tableEnv.executeSql("CREATE TABLE test2b (a INT)");
> List<Row> results =
> CollectionUtil.iteratorToList(
> tableEnv.executeSql(
> "select * from test2b join test2a on
> test2b.a = test2a.a[1]")
> .collect());
> {code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
