From e25b0d7c378a3287d5bd5ca173d3448a8d09abab Mon Sep 17 00:00:00 2001 From: zy-kkk Date: Sat, 29 Jun 2024 18:35:41 +0800 Subject: [PATCH] [branch-2.1][improvement](mysql catalog) disable mysql AbandonedConnectionCleanupThread (#36970) pick (#36655) --- .../src/main/java/org/apache/doris/jdbc/MySQLJdbcExecutor.java | 1 + .../apache/doris/datasource/jdbc/client/JdbcMySQLClient.java | 2 ++ 2 files changed, 3 insertions(+) diff --git a/fe/be-java-extensions/jdbc-scanner/src/main/java/org/apache/doris/jdbc/MySQLJdbcExecutor.java b/fe/be-java-extensions/jdbc-scanner/src/main/java/org/apache/doris/jdbc/MySQLJdbcExecutor.java index 6a7e2affd5..5cdd30a975 100644 --- a/fe/be-java-extensions/jdbc-scanner/src/main/java/org/apache/doris/jdbc/MySQLJdbcExecutor.java +++ b/fe/be-java-extensions/jdbc-scanner/src/main/java/org/apache/doris/jdbc/MySQLJdbcExecutor.java @@ -48,6 +48,7 @@ public class MySQLJdbcExecutor extends BaseJdbcExecutor { public MySQLJdbcExecutor(byte[] thriftParams) throws Exception { super(thriftParams); + System.setProperty("com.mysql.cj.disableAbandonedConnectionCleanup", "true"); } @Override diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/client/JdbcMySQLClient.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/client/JdbcMySQLClient.java index efb69d8003..f58753bcce 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/client/JdbcMySQLClient.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/client/JdbcMySQLClient.java @@ -45,6 +45,8 @@ public class JdbcMySQLClient extends JdbcClient { protected JdbcMySQLClient(JdbcClientConfig jdbcClientConfig) { super(jdbcClientConfig); + // Disable abandoned connection cleanup + System.setProperty("com.mysql.cj.disableAbandonedConnectionCleanup", "true"); convertDateToNull = isConvertDatetimeToNull(jdbcClientConfig); Connection conn = null; Statement stmt = null;