change to current catalog

2020-05-16 21:12:46 +08:00
parent c50b1a4d17
commit 8cb48161e3
1 changed files with 1 additions and 1 deletions
--- 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);
            }