4

xinyiZzz · Jan 1, 2025 · 59404d6 · 59404d6
1 parent 9e219a9
commit 59404d6
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/FlightSqlSchemaHelper.java b/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/FlightSqlSchemaHelper.java
@@ -17,7 +17,9 @@
 
 package org.apache.doris.service.arrowflight;
 
+import org.apache.doris.catalog.Env;
 import org.apache.doris.catalog.PrimitiveType;
+import org.apache.doris.datasource.CatalogIf;
 import org.apache.doris.qe.ConnectContext;
 import org.apache.doris.service.ExecuteEnv;
 import org.apache.doris.service.FrontendServiceImpl;
@@ -318,8 +320,9 @@ public void getCatalogs(VectorSchemaRoot vectorSchemaRoot) throws TException {
 
         Set<String> catalogsSet = new LinkedHashSet<>();
         catalogsSet.add("internal"); // An ordered Set with "internal" first.
-        TGetDbsResult getDbsResult = getDbNames();
-        catalogsSet.addAll(getDbsResult.getCatalogs());
+        for (CatalogIf catalog : Env.getCurrentEnv().getCatalogMgr().listCatalogs()) {
+            catalogsSet.add(catalog.getName());
+        }
 
         int catalogIndex = 0;
         for (String catalog : catalogsSet) {