[
https://issues.apache.org/jira/browse/FLINK-37850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-37850.
-------------------------------------
Fix Version/s: 2.1.0
Resolution: Fixed
> Several Union, Except, Intersect with one wrong column type fail with
> UnsupportedOperationException
> ---------------------------------------------------------------------------------------------------
>
> Key: FLINK-37850
> URL: https://issues.apache.org/jira/browse/FLINK-37850
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / Planner
> Reporter: Sergey Nuyanzin
> Assignee: Sergey Nuyanzin
> Priority: Major
> Labels: pull-request-available
> Fix For: 2.1.0
>
>
> Example of failing query
> {code:scala}
> val sqlQuery =
> """
> | SELECT id, ts, name, timestamp_col, timestamp_ltz_col FROM t2
> | UNION ALL
> | SELECT id, ts, name, timestamp_col, timestamp_ltz_col FROM t3
> | UNION ALL
> | SELECT id, ts, timestamp_col as wrong_column_type, timestamp_col,
> timestamp_ltz_col FROM t2
> """.stripMargin
> util.verifyRelPlanWithType(sqlQuery)
> {code}
> fails with
> {noformat}
> Caused by: java.lang.UnsupportedOperationException: class
> org.apache.calcite.sql.SqlBasicCall: SELECT `t2`.`id`, `t2`.`ts`,
> `t2`.`name`, `t2`.`timestamp_col`, `t2`.`timestamp_ltz_col`
> FROM `default_catalog`.`default_database`.`t2` AS `t2`
> UNION ALL
> SELECT `t3`.`id`, `t3`.`ts`, `t3`.`name`, `t3`.`timestamp_col`,
> `t3`.`timestamp_ltz_col`
> FROM `default_catalog`.`default_database`.`t3` AS `t3`
> {noformat}
> the root cause is issue in Calcite (fixed in 1.40)
> CALCITE-7027
--
This message was sent by Atlassian Jira
(v8.20.10#820010)