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 cd89ea8199..4a91ab1ac9 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 class MySqlPlugin extends BasePlugin { */ 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 ae001730f3..a9921eab4c 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 @@ import static org.springframework.util.CollectionUtils.isEmpty; 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 6f9cbd498a..e2a7bed2a0 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 -> {