From ca500bc4812d987ccf9f94131229adf8cb3286e9 Mon Sep 17 00:00:00 2001 From: Jingsong Date: Wed, 25 Sep 2024 17:10:45 +0800 Subject: [PATCH] fux --- .../src/main/java/org/apache/paimon/jdbc/JdbcCatalog.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcCatalog.java b/paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcCatalog.java index e52bc9d6b173..3f44a92a5d52 100644 --- a/paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcCatalog.java +++ b/paimon-core/src/main/java/org/apache/paimon/jdbc/JdbcCatalog.java @@ -82,10 +82,7 @@ protected JdbcCatalog(FileIO fileIO, String catalogKey, Options options, String this.warehouse = warehouse; Preconditions.checkNotNull(options, "Invalid catalog properties: null"); this.connections = - new JdbcClientPool( - options.get(CatalogOptions.CLIENT_POOL_SIZE), - options.get(CatalogOptions.URI.key()), - options.toMap()); + new JdbcClientPool(1, options.get(CatalogOptions.URI.key()), options.toMap()); try { initializeCatalogTablesIfNeed(); } catch (SQLException e) {