[jira] [Created] (FLINK-26761) Fix the cast exception thrown by PreValidateReWriter when insert into/overwrite a partitioned table.

["zoucao (Jira)" <ji...@apache.org>]

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)