You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by Caizhi Weng <ts...@gmail.com> on 2021/09/01 02:14:11 UTC

Re: Could not execute ALTER TABLE check_rule_base_hive_catalog.test_flink.test_partition DROP PARTITION (dt=2021-08-31)

Hi！

目前 Flink SQL Hive 方言应该是没有支持指定 partial partition 然后 drop。可以提一个 jira 描述一下这个需求。

Asahi Lee <97...@qq.com.invalid> 于2021年8月31日周二 下午2:03写道：

> hi!
> 我是用flink 1.13.1版本，使用hive方言删除dt分区错误，同样的sql hive是可以成功的！
> 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]