diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java index 370077f67ddf1b..e571b18c2ae107 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java @@ -1019,14 +1019,14 @@ private void dropTableInternal(Database db, Table table, boolean isView, boolean costTimes.put("5:getRecycleTimeById", watch.getSplitTime()); } } + DropInfo info = new DropInfo(db.getId(), table.getId(), tableName, isView, forceDrop, recycleTime); + Env.getCurrentEnv().getEditLog().logDropTable(info); } finally { table.writeUnlock(); } Env.getCurrentEnv().getQueryStats().clear(Env.getCurrentEnv().getCurrentCatalog().getId(), db.getId(), table.getId()); - DropInfo info = new DropInfo(db.getId(), table.getId(), tableName, isView, forceDrop, recycleTime); - Env.getCurrentEnv().getEditLog().logDropTable(info); Env.getCurrentEnv().getMtmvService().dropTable(table); if (Config.isCloudMode()) { ((CloudGlobalTransactionMgr) Env.getCurrentGlobalTransactionMgr())