From 80d5e0ddaa5c369f5bbb99562c46c86d94b6d9c1 Mon Sep 17 00:00:00 2001 From: sunxiaojian Date: Fri, 31 May 2024 18:16:51 +0800 Subject: [PATCH] fixed --- .../src/main/java/org/apache/paimon/catalog/Catalog.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/paimon-core/src/main/java/org/apache/paimon/catalog/Catalog.java b/paimon-core/src/main/java/org/apache/paimon/catalog/Catalog.java index 106f7b15afd7..d2a7db8217fb 100644 --- a/paimon-core/src/main/java/org/apache/paimon/catalog/Catalog.java +++ b/paimon-core/src/main/java/org/apache/paimon/catalog/Catalog.java @@ -25,6 +25,7 @@ import org.apache.paimon.schema.Schema; import org.apache.paimon.schema.SchemaChange; import org.apache.paimon.table.Table; +import org.apache.paimon.utils.BranchManager; import java.io.Serializable; import java.util.Arrays; @@ -270,7 +271,12 @@ default void invalidateTable(Identifier identifier) {} * @throws TableNotExistException if the table does not exist * @throws PartitionNotExistException if the partition does not exist */ - void dropPartition(Identifier identifier, Map partitions) + default void dropPartition(Identifier identifier, Map partitions) + throws TableNotExistException, PartitionNotExistException { + dropPartition(identifier, partitions, BranchManager.DEFAULT_MAIN_BRANCH); + } + + void dropPartition(Identifier identifier, Map partitions, String branch) throws TableNotExistException, PartitionNotExistException; /**