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 106f7b15afd79..d2a7db8217fb0 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; /**