diff --git a/fe/src/main/java/org/apache/doris/service/FrontendServiceImpl.java b/fe/src/main/java/org/apache/doris/service/FrontendServiceImpl.java index 3ec703294560ee..057d3cdb9591d9 100644 --- a/fe/src/main/java/org/apache/doris/service/FrontendServiceImpl.java +++ b/fe/src/main/java/org/apache/doris/service/FrontendServiceImpl.java @@ -808,7 +808,8 @@ private void loadTxnRollbackImpl(TLoadTxnRollbackRequest request) throws UserExc checkPasswordAndPrivs(cluster, request.getUser(), request.getPasswd(), request.getDb(), request.getTbl(), request.getUser_ip(), PrivPredicate.LOAD); } - Database db = Catalog.getInstance().getDb(request.getDb()); + String dbName = ClusterNamespace.getFullName(cluster, request.getDb()); + Database db = Catalog.getInstance().getDb(dbName); if (db == null) { throw new MetaNotFoundException("db " + request.getDb() + " does not exist"); }