diff --git a/app/server/appsmith-plugins/mysqlPlugin/src/main/java/com/external/plugins/MySqlPlugin.java b/app/server/appsmith-plugins/mysqlPlugin/src/main/java/com/external/plugins/MySqlPlugin.java index cd89ea81992e..4a91ab1ac90f 100644 --- a/app/server/appsmith-plugins/mysqlPlugin/src/main/java/com/external/plugins/MySqlPlugin.java +++ b/app/server/appsmith-plugins/mysqlPlugin/src/main/java/com/external/plugins/MySqlPlugin.java @@ -692,12 +692,11 @@ public void datasourceDestroy(ConnectionContext connectionContex */ sshTunnelContext.getServerSocket().close(); sshTunnelContext.getSshClient().disconnect(); - sshTunnelContext.getThread().stop(); + sshTunnelContext.getThread().interrupt(); // Gracefully interrupt the thread } catch (IOException e) { log.error("Failed to destroy SSH tunnel context: " + e.getMessage()); } } - return Mono.empty(); }) .subscribeOn(scheduler) diff --git a/app/server/appsmith-plugins/mysqlPlugin/src/main/java/com/external/utils/MySqlDatasourceUtils.java b/app/server/appsmith-plugins/mysqlPlugin/src/main/java/com/external/utils/MySqlDatasourceUtils.java index ae001730f3a3..a9921eab4cab 100644 --- a/app/server/appsmith-plugins/mysqlPlugin/src/main/java/com/external/utils/MySqlDatasourceUtils.java +++ b/app/server/appsmith-plugins/mysqlPlugin/src/main/java/com/external/utils/MySqlDatasourceUtils.java @@ -38,7 +38,7 @@ public class MySqlDatasourceUtils { - public static int MAX_CONNECTION_POOL_SIZE = 5; + public static int MAX_CONNECTION_POOL_SIZE = 20; /** * 1 sec is the recommended value as shown in the example here: diff --git a/app/server/appsmith-server/src/test/java/com/appsmith/server/connectionpoolconfig/configurations/ConnectionPoolConfigCETest.java b/app/server/appsmith-server/src/test/java/com/appsmith/server/connectionpoolconfig/configurations/ConnectionPoolConfigCETest.java index 6f9cbd498a99..e2a7bed2a02f 100644 --- a/app/server/appsmith-server/src/test/java/com/appsmith/server/connectionpoolconfig/configurations/ConnectionPoolConfigCETest.java +++ b/app/server/appsmith-server/src/test/java/com/appsmith/server/connectionpoolconfig/configurations/ConnectionPoolConfigCETest.java @@ -18,7 +18,7 @@ public class ConnectionPoolConfigCETest { @Test public void verifyGetMaxConnectionPoolSizeProvidesDefaultValue() { // this is same as default - Integer connectionPoolMaxSize = 5; + Integer connectionPoolMaxSize = 20; Mono connectionPoolMaxSizeMono = connectionPoolConfig.getMaxConnectionPoolSize(); StepVerifier.create(connectionPoolMaxSizeMono).assertNext(poolSize -> {