zoucao created FLINK-26761: ------------------------------ Summary: 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
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)