From 0591c03ca46f6a70b788b903d608ed9f76f62b95 Mon Sep 17 00:00:00 2001 From: taojinlong Date: Mon, 21 Apr 2025 15:48:56 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E8=AE=BE=E7=BD=AE=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E6=BA=90=E9=93=BE=E6=8E=A5=E6=B1=A0=E8=B6=85=E6=97=B6=E6=97=B6?= =?UTF-8?q?=E9=97=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/io/dataease/datasource/provider/CalciteProvider.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/core/core-backend/src/main/java/io/dataease/datasource/provider/CalciteProvider.java b/core/core-backend/src/main/java/io/dataease/datasource/provider/CalciteProvider.java index 159a476f9e..22fb35f531 100644 --- a/core/core-backend/src/main/java/io/dataease/datasource/provider/CalciteProvider.java +++ b/core/core-backend/src/main/java/io/dataease/datasource/provider/CalciteProvider.java @@ -947,6 +947,7 @@ public class CalciteProvider extends Provider { commonThreadPool.addTask(() -> { try { BasicDataSource dataSource = new BasicDataSource(); + dataSource.setMaxWaitMillis(5 * 1000); Schema schema = null; DatasourceConfiguration configuration = null; DatasourceConfiguration.DatasourceType datasourceType = DatasourceConfiguration.DatasourceType.valueOf(ds.getType()); @@ -1690,6 +1691,7 @@ public class CalciteProvider extends Provider { } JdbcSchema jdbcSchema = rootSchema.getSubSchema(String.format(SQLConstants.SCHEMA, dsId)).unwrap(JdbcSchema.class); BasicDataSource basicDataSource = (BasicDataSource) jdbcSchema.getDataSource(); + basicDataSource.setMaxWaitMillis(5 * 1000); return basicDataSource.getConnection(); } catch (Exception e) { DEException.throwException(Translator.get("i18n_invalid_connection") + e.getMessage());