[
https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-26761:
------------------------------
Fix Version/s: 2.3.0
(was: 2.2.0)
> Fix the cast exception thrown by PreValidateReWriter when insert
> into/overwrite a partitioned table.
> ----------------------------------------------------------------------------------------------------
>
> Key: FLINK-26761
> URL: https://issues.apache.org/jira/browse/FLINK-26761
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Planner
> Affects Versions: 2.1.0
> Reporter: zoucao
> Priority: Major
> Labels: pull-request-available
> Fix For: 2.3.0
>
>
> In `PreValidateReWriter#appendPartitionAndNullsProjects`, we should use
> {code:java}
> val names = sqlInsert.getTargetTableID.asInstanceOf[SqlIdentifier].names
> {code}
> to get the table name, instead of
> {code:java}
> val names = sqlInsert.getTargetTable.asInstanceOf[SqlIdentifier].names
> {code}
> when we execute the following sql:
> {code:java}
> insert into/overwrite table_name /*+ options(xxx) */ partition(xxx) select
> {code}
> invoke `sqlInsert.getTargetTable` will get a SqlTableRef, which can not be
> cast to SqlIdentifier.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
