[
https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520941#comment-17520941
]
zoucao commented on FLINK-26761:
--------------------------------
Sure, [~godfreyhe]， plz assign it to me.
> 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
> Reporter: zoucao
> Priority: Major
> Fix For: 1.16.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.1#820001)
