From d8d87965bb96b87c95cae7aef448ae5d2b020c30 Mon Sep 17 00:00:00 2001 From: zhilinli Date: Mon, 19 Jun 2023 12:27:31 +0800 Subject: [PATCH] [Bug] [E2E] mysql-cdc e2e error #4944 --- .../base/relational/connection/JdbcConnectionPoolFactory.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/relational/connection/JdbcConnectionPoolFactory.java b/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/relational/connection/JdbcConnectionPoolFactory.java index 9a9df595928..0899469d2a9 100644 --- a/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/relational/connection/JdbcConnectionPoolFactory.java +++ b/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/relational/connection/JdbcConnectionPoolFactory.java @@ -48,7 +48,7 @@ public HikariDataSource createPooledDataSource(JdbcSourceConfig sourceConfig) { config.addDataSourceProperty("cachePrepStmts", "true"); config.addDataSourceProperty("prepStmtCacheSize", "250"); config.addDataSourceProperty("prepStmtCacheSqlLimit", "2048"); - + config.setDriverClassName(sourceConfig.getDriverClassName()); return new HikariDataSource(config); }