[
https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17512274#comment-17512274
]
zoucao commented on FLINK-26761:
--------------------------------
cc [~Leonard] , could you help me to confirm it, maybe Jack is too busy to
notice this.
> 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
>
> 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)
