[
https://issues.apache.org/jira/browse/FLINK-26542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26542:
-----------------------------
Description:
With Hive dialect, when select cluster contains multiple same columns, it'll
will throw
{code:java}
tableEnv.executeSql("create table src(key string, value string)");
tableEnv.executeSql("create table src2(key string, value string)");
List<Row> results =
queryResult(
tableEnv.sqlQuery(
"select key, value from src union all select
key, key from src2"));
{code}
was:
With Hive dialect, for union SQL statement, when one side of union selects
multiple fields with same name, the fields will be overwritten and then only
retain one field. Then, it will throw the exception " Schema of both sides of
union should match".
The exception can be reproduced using following code:
{code:java}
tableEnv.executeSql("create table src(key string, value string)");
tableEnv.executeSql("create table src2(key string, value string)");
List<Row> results =
queryResult(
tableEnv.sqlQuery(
"select key, value from src union all select
key, key from src2"));
{code}
> Hive dialect supports queries with multiple same columns in select
> -------------------------------------------------------------------
>
> Key: FLINK-26542
> URL: https://issues.apache.org/jira/browse/FLINK-26542
> Project: Flink
> Issue Type: Sub-task
> Components: Connectors / Hive
> Reporter: luoyuxia
> Priority: Major
> Fix For: 1.16.0
>
>
> With Hive dialect, when select cluster contains multiple same columns,
> it'll will throw
> {code:java}
> tableEnv.executeSql("create table src(key string, value string)");
> tableEnv.executeSql("create table src2(key string, value string)");
> List<Row> results =
> queryResult(
> tableEnv.sqlQuery(
> "select key, value from src union all select
> key, key from src2"));
> {code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
