Skip to content

Commit d37fc80

Browse files
Jiabao-Sunzhangchaoming.zcm
authored andcommitted
[hotfix][mysql] Set minimum connection pool size to 1 (apache#692)
1 parent e4c7a0f commit d37fc80

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
@@ -30,6 +30,7 @@ public class PooledDataSourceFactory {
3030
"jdbc:mysql://%s:%s/?useInformationSchema=true&nullCatalogMeansCurrent=false&useUnicode=true&characterEncoding=UTF-8&characterSetResults=UTF-8&zeroDateTimeBehavior=CONVERT_TO_NULL";
3131
public static final String CONNECTION_POOL_PREFIX = "connection-pool-";
3232
public static final String SERVER_TIMEZONE_KEY = "serverTimezone";
33+
public static final int MINIMUM_POOL_SIZE = 1;
3334

3435
private PooledDataSourceFactory() {}
3536

@@ -43,6 +44,7 @@ public static HikariDataSource createPooledDataSource(MySqlSourceConfig sourceCo
4344
config.setJdbcUrl(String.format(JDBC_URL_PATTERN, hostName, port));
4445
config.setUsername(sourceConfig.getUsername());
4546
config.setPassword(sourceConfig.getPassword());
47+
config.setMinimumIdle(MINIMUM_POOL_SIZE);
4648
config.setMaximumPoolSize(sourceConfig.getConnectionPoolSize());
4749
config.setConnectionTimeout(sourceConfig.getConnectTimeout().toMillis());
4850
config.addDataSourceProperty(SERVER_TIMEZONE_KEY, sourceConfig.getServerTimeZone());

0 commit comments

Comments
 (0)