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

[kunni]

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 <676366...@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);
     }