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)
