From 51bf946ac602284c0b5fe10c07d2f867860ca37b Mon Sep 17 00:00:00 2001
From: Zou Xinyi <zouxinyi@selectdb.com>
Date: Tue, 31 Dec 2024 11:36:59 +0800
Subject: [PATCH] 2

---
 .../doris/service/arrowflight/FlightSqlSchemaHelper.java     | 5 ++++-
 1 file changed, 4 insertions(+), 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
index aec6d3655e57113..c5a0d0a19b6ca4f 100644
--- 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);
     }