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

2025-03-18 Thread Weijie Guo (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Weijie Guo updated FLINK-26761:
---
Fix Version/s: 2.1.0
   (was: 2.0.0)

> 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
>Affects Versions: 2.1.0
>Reporter: zoucao
>Priority: Major
>  Labels: pull-request-available
> Fix For: 2.1.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.10#820010)

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

2025-03-18 Thread Weijie Guo (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Weijie Guo updated FLINK-26761:
---
Affects Version/s: 2.1.0

> 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
>Affects Versions: 2.1.0
>Reporter: zoucao
>Priority: Major
>  Labels: pull-request-available
> Fix For: 2.0.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.10#820010)

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

2024-07-10 Thread Weijie Guo (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Weijie Guo updated FLINK-26761:
---
Fix Version/s: 2.0.0
   (was: 1.20.0)

> 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
>  Labels: pull-request-available
> Fix For: 2.0.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.10#820010)

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

2024-03-11 Thread lincoln lee (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

lincoln lee updated FLINK-26761:

Fix Version/s: (was: 1.19.0)

> 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
>  Labels: pull-request-available
> Fix For: 1.20.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.10#820010)

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

2024-03-11 Thread lincoln lee (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

lincoln lee updated FLINK-26761:

Fix Version/s: 1.20.0

> 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
>  Labels: pull-request-available
> Fix For: 1.19.0, 1.20.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.10#820010)

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

2023-10-13 Thread Jing Ge (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Jing Ge updated FLINK-26761:

Fix Version/s: 1.19.0
   (was: 1.18.0)

> 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
>  Labels: pull-request-available
> Fix For: 1.19.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.10#820010)

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

2023-03-23 Thread Xintong Song (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Xintong Song updated FLINK-26761:
-
Fix Version/s: 1.18.0
   (was: 1.17.0)

> 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
>  Labels: pull-request-available
> Fix For: 1.18.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.10#820010)

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

2022-09-30 Thread Huang Xingbo (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Huang Xingbo updated FLINK-26761:
-
Fix Version/s: 1.17.0
   (was: 1.16.0)

> 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
>  Labels: pull-request-available
> Fix For: 1.17.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.10#820010)

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

2022-04-18 Thread ASF GitHub Bot (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

ASF GitHub Bot updated FLINK-26761:
---
Labels: pull-request-available  (was: )

> 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
>  Labels: pull-request-available
> 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)

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

2022-04-11 Thread godfrey he (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

godfrey he updated FLINK-26761:
---
Fix Version/s: 1.16.0

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