diff --git a/fe/src/main/java/org/apache/doris/catalog/CatalogRecycleBin.java b/fe/src/main/java/org/apache/doris/catalog/CatalogRecycleBin.java index 0257f6425e..230790855d 100644 --- a/fe/src/main/java/org/apache/doris/catalog/CatalogRecycleBin.java +++ b/fe/src/main/java/org/apache/doris/catalog/CatalogRecycleBin.java @@ -174,7 +174,7 @@ public class CatalogRecycleBin extends MasterDaemon implements Writable { idToRecycleTime.remove(entry.getKey()); // remove database transaction manager - Catalog.getInstance().getGlobalTransactionMgr().removeDatabaseTransactionMgr(db.getId()); + Catalog.getCurrentCatalog().getGlobalTransactionMgr().removeDatabaseTransactionMgr(db.getId()); LOG.info("erase database[{}] name: {}", db.getId(), dbName); }