You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "luoyuxia (Jira)" <ji...@apache.org> on 2022/03/09 03:41:00 UTC
[jira] [Created] (FLINK-26542) Fix the issue that schema of both sides of union won't match when one side of union select fields with same names
luoyuxia created FLINK-26542:
--------------------------------
Summary: Fix the issue that schema of both sides of union won't match when one side of union select fields with same names
Key: FLINK-26542
URL: https://issues.apache.org/jira/browse/FLINK-26542
Project: Flink
Issue Type: Sub-task
Components: Connectors / Hive
Reporter: luoyuxia
Fix For: 1.16.0
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}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)