From aa3e282cfdc10c8c6dc3dac7b361924ba435fab9 Mon Sep 17 00:00:00 2001 From: Leonard Xu Date: Fri, 5 Nov 2021 10:54:52 +0800 Subject: [PATCH] [mysql] Set server time zone information for connection pool factory (#566) --- .../mysql/source/connection/PooledDataSourceFactory.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/connection/PooledDataSourceFactory.java b/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/connection/PooledDataSourceFactory.java index 1602b4afa..cb45c5b4e 100644 --- a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/connection/PooledDataSourceFactory.java +++ b/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/connection/PooledDataSourceFactory.java @@ -28,6 +28,7 @@ public class PooledDataSourceFactory { public static final String JDBC_URL_PATTERN = "jdbc:mysql://%s:%s/?useInformationSchema=true&nullCatalogMeansCurrent=false&useUnicode=true&characterEncoding=UTF-8&characterSetResults=UTF-8&zeroDateTimeBehavior=CONVERT_TO_NULL"; public static final String CONNECTION_POOL_PREFIX = "connection-pool-"; + public static final String SERVER_TIMEZONE_KEY = "serverTimezone"; private PooledDataSourceFactory() {} @@ -43,6 +44,7 @@ public class PooledDataSourceFactory { config.setPassword(sourceConfig.getPassword()); config.setMaximumPoolSize(sourceConfig.getConnectionPoolSize()); config.setConnectionTimeout(sourceConfig.getConnectTimeout().toMillis()); + config.addDataSourceProperty(SERVER_TIMEZONE_KEY, sourceConfig.getServerTimeZone()); // optional optimization configurations for pooled DataSource config.addDataSourceProperty("cachePrepStmts", "true");