You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ku...@apache.org on 2026/01/04 01:53:34 UTC

(flink-cdc) branch master updated: [FLINK-38847][postgres] Update PostgresConnectionPoolFactory#getPoolId method to use username correctly. (#4204)

This is an automated email from the ASF dual-hosted git repository.

kunni pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git


The following commit(s) were added to refs/heads/master by this push:
     new 533072b6b [FLINK-38847][postgres] Update PostgresConnectionPoolFactory#getPoolId method to use username correctly. (#4204)
533072b6b is described below

commit 533072b6bbbc266df7824b47433682885c123948
Author: wudi <67...@qq.com>
AuthorDate: Sun Jan 4 09:53:30 2026 +0800

    [FLINK-38847][postgres] Update PostgresConnectionPoolFactory#getPoolId method to use username correctly. (#4204)
---
 .../cdc/connectors/postgres/source/PostgresConnectionPoolFactory.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresConnectionPoolFactory.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresConnectionPoolFactory.java
index 3c96622e5..8a73ac17f 100644
--- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresConnectionPoolFactory.java
+++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresConnectionPoolFactory.java
@@ -47,7 +47,7 @@ public class PostgresConnectionPoolFactory extends JdbcConnectionPoolFactory {
         return new ConnectionPoolId(
                 config.getHostname(),
                 config.getPort(),
-                config.getHostname(),
+                config.getUser(),
                 config.getDatabase(),
                 dataSourcePoolFactoryIdentifier);
     }