From 39212e87af95f100dcf1b31083355e52f534a321 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 96e85d20a0099..a120067f194f1 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 @@ -24,6 +24,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.Collections; @@ -234,7 +235,12 @@ void alterTable(Identifier identifier, List changes, boolean ignor * @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; /**