Skip to content

Commit aa3e282

Browse files
authored
[mysql] Set server time zone information for connection pool factory (#566)
1 parent 7f32e4d commit aa3e282

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/connection/PooledDataSourceFactory.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@ public class PooledDataSourceFactory {
2828
public static final String JDBC_URL_PATTERN =
2929
"jdbc:mysql://%s:%s/?useInformationSchema=true&nullCatalogMeansCurrent=false&useUnicode=true&characterEncoding=UTF-8&characterSetResults=UTF-8&zeroDateTimeBehavior=CONVERT_TO_NULL";
3030
public static final String CONNECTION_POOL_PREFIX = "connection-pool-";
31+
public static final String SERVER_TIMEZONE_KEY = "serverTimezone";
3132

3233
private PooledDataSourceFactory() {}
3334

@@ -43,6 +44,7 @@ public static HikariDataSource createPooledDataSource(MySqlSourceConfig sourceCo
4344
config.setPassword(sourceConfig.getPassword());
4445
config.setMaximumPoolSize(sourceConfig.getConnectionPoolSize());
4546
config.setConnectionTimeout(sourceConfig.getConnectTimeout().toMillis());
47+
config.addDataSourceProperty(SERVER_TIMEZONE_KEY, sourceConfig.getServerTimeZone());
4648

4749
// optional optimization configurations for pooled DataSource
4850
config.addDataSourceProperty("cachePrepStmts", "true");

0 commit comments

Comments
 (0)