You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Jing Zhang (Jira)" <ji...@apache.org> on 2022/04/02 14:36:00 UTC
[jira] [Commented] (FLINK-26540) Support handle join involving complex types in on condition
[ https://issues.apache.org/jira/browse/FLINK-26540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516320#comment-17516320 ]
Jing Zhang commented on FLINK-26540:
------------------------------------
fixed in master: 0e459bf810736347ad7bf1eb62be4dad3382392e
> 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)