[ 
https://issues.apache.org/jira/browse/FLINK-26362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

luoyuxia updated FLINK-26362:
-----------------------------
    Description: 
With hive dialect, can be reproduced using following code:

{code:java}
 tableEnv.executeSql("CREATE TABLE t1 (c1 INT, c2 CHAR(100))");
 tableEnv.executeSql("CREATE TABLE t2 (c1 INT)");
List<Row> results = CollectionUtil.iteratorToList(tableEnv.executeSql("SELECT 
c1 FROM t1 WHERE c1 IN (SELECT c1 FROM t2)").
                        collect());
{code}

Then it will throw index


> "IndexOutOfBoundsException" when subquery select all field from using hive 
> dialect
> ----------------------------------------------------------------------------------
>
>                 Key: FLINK-26362
>                 URL: https://issues.apache.org/jira/browse/FLINK-26362
>             Project: Flink
>          Issue Type: Sub-task
>            Reporter: luoyuxia
>            Priority: Major
>
> With hive dialect, can be reproduced using following code:
> {code:java}
>  tableEnv.executeSql("CREATE TABLE t1 (c1 INT, c2 CHAR(100))");
>  tableEnv.executeSql("CREATE TABLE t2 (c1 INT)");
> List<Row> results = CollectionUtil.iteratorToList(tableEnv.executeSql("SELECT 
> c1 FROM t1 WHERE c1 IN (SELECT c1 FROM t2)").
>                         collect());
> {code}
> Then it will throw index



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Reply via email to