[ 
https://issues.apache.org/jira/browse/FLINK-24094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408443#comment-17408443
 ] 

luoyuxia edited comment on FLINK-24094 at 9/2/21, 12:08 AM:
------------------------------------------------------------

[~leexu] Thanks for reporting.

Yeah, hive supports it. But I can't figure out why it shouldn't be allowed for 
hive catalog in flink.

Maybe we can support it. [~jark] WDYT, I would like to do that.


was (Author: luoyuxia):
Yeah, hive supoorts it. But I can't figure out why it shouldn't be allowed for 
hive catalog in flink.

Maybe we can support it. [~jark] WDYT, I would like to do that.

> Support DROP PARTITION by partial partition specification
> ---------------------------------------------------------
>
>                 Key: FLINK-24094
>                 URL: https://issues.apache.org/jira/browse/FLINK-24094
>             Project: Flink
>          Issue Type: New Feature
>          Components: Connectors / Hive
>    Affects Versions: 1.13.1
>            Reporter: lixu
>            Priority: Major
>             Fix For: 1.15.0
>
>
> [https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/connectors/table/hive/hive_dialect/#drop-partitions]
> {code:java}
> //代码占位符
> Caused by: 
> org.apache.flink.table.catalog.exceptions.PartitionSpecInvalidException: 
> PartitionSpec CatalogPartitionSpec{{dt=2021-08-31}} does not match partition 
> keys [dt, xtlx, sblx] of table test_flink.test_partition in catalog 
> check_rule_base_hive_catalog.    at 
> org.apache.flink.table.catalog.hive.HiveCatalog.getOrderedFullPartitionValues(HiveCatalog.java:1189)
>  ~[flink-sql-connector-hive-2.3.6_2.11-1.13.1.jar:1.13.1]        at 
> org.apache.flink.table.catalog.hive.HiveCatalog.dropPartition(HiveCatalog.java:899)
>  ~[flink-sql-connector-hive-2.3.6_2.11-1.13.1.jar:1.13.1] at 
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:982)
>  ~[flink-table-blink_2.11-1.13.1.jar:1.13.1]  at 
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:730)
>  ~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to