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 3ec7032945..057d3cdb95 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 @@ public class FrontendServiceImpl implements FrontendService.Iface { 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"); }