Skip to content

Commit 8ba4051

Browse files
committed
fix
1 parent 6beca20 commit 8ba4051

File tree

1 file changed

+1
-7
lines changed
  • paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive

1 file changed

+1
-7
lines changed

paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,6 @@
4646
import org.apache.paimon.table.CatalogTableType;
4747
import org.apache.paimon.table.FileStoreTable;
4848
import org.apache.paimon.table.FormatTable;
49-
import org.apache.paimon.table.sink.BatchTableCommit;
5049
import org.apache.paimon.types.DataField;
5150
import org.apache.paimon.types.DataTypes;
5251
import org.apache.paimon.types.RowType;
@@ -431,12 +430,7 @@ public void dropPartitions(Identifier identifier, List<Map<String, String>> part
431430
}
432431
}
433432
if (!tagToPart) {
434-
org.apache.paimon.table.Table table = getTable(identifier);
435-
try (BatchTableCommit commit = table.newBatchWriteBuilder().newCommit()) {
436-
commit.truncatePartitions(partitions);
437-
} catch (Exception e) {
438-
throw new RuntimeException(e);
439-
}
433+
dropPartitions(identifier, partitions);
440434
}
441435
}
442436

0 commit comments

Comments
 (0)