From f43e66f2845a690175a8430245a6c5c9ceae71ac Mon Sep 17 00:00:00 2001 From: deardeng Date: Fri, 5 Sep 2025 11:50:50 +0800 Subject: [PATCH] [fix](table) Move drop editlog in table lock --- .../java/org/apache/doris/datasource/InternalCatalog.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 d5895948669b3f..3f4abbc474d5ee 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 @@ -987,13 +987,13 @@ 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(); } - DropInfo info = new DropInfo(db.getId(), table.getId(), tableName, isView, forceDrop, recycleTime); Env.getCurrentEnv().getMtmvService().dropTable(table); - Env.getCurrentEnv().getEditLog().logDropTable(info); if (Config.isCloudMode()) { ((CloudGlobalTransactionMgr) Env.getCurrentGlobalTransactionMgr()) .clearTableLastTxnId(db.getId(), table.getId());