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); }