2

xinyiZzz · Dec 31, 2024 · 51bf946 · 51bf946
1 parent 6d370c0
commit 51bf946
Showing 1 changed file with 4 additions and 1 deletion.
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
@@ -79,7 +79,10 @@ public FlightSqlSchemaHelper(ConnectContext context) {
      */
     private TGetDbsResult getDbNames() throws TException {
         TGetDbsParams getDbsParams = new TGetDbsParams();
-        // getDbsParams.setPattern("tes%");
+        // Default get Internal Catalog, which is consistent with `jdbc:mysql`.
+        // Otherwise, if the configured ExternalCatalog cannot be connected,
+        // `catalog.getAllDbs()` will be stuck and wait until the timeout period ends.
+        getDbsParams.setCatalog("internal");
         getDbsParams.setCurrentUserIdent(ctx.getCurrentUserIdentity().toThrift());
         return impl.getDbNames(getDbsParams);
     }