Hongshun Wang created FLINK-35524: ------------------------------------- Summary: Clear connections pools when reader exist. Key: FLINK-35524 URL: https://issues.apache.org/jira/browse/FLINK-35524 Project: Flink Issue Type: Bug Components: Flink CDC Affects Versions: cdc-3.1.1 Reporter: Hongshun Wang Fix For: cdc-3.2.0
Current, inJdbcConnectionPools is static instance, so the datasource pools in it won't be recycle when reader close. It will cause memory leak. ```java public class JdbcConnectionPools implements ConnectionPools<HikariDataSource, JdbcSourceConfig> { private static final Logger LOG = LoggerFactory.getLogger(JdbcConnectionPools.class); private static JdbcConnectionPools instance; private final Map<ConnectionPoolId, HikariDataSource> pools = new HashMap<>(); private static final Map<String, JdbcConnectionPoolFactory> POOL_FACTORY_MAP = new HashMap<>(); ``` -- This message was sent by Atlassian Jira (v8.20.10#820010)