[ 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)