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]

Reply via email to