Skip to content

Commit 93741bb

Browse files
JNSimbaMrart
authored andcommitted
[FLINK-38847][postgres] Update PostgresConnectionPoolFactory#getPoolId method to use username correctly. (apache#4204)
1 parent 012665f commit 93741bb

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresConnectionPoolFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ public ConnectionPoolId getPoolId(
4747
return new ConnectionPoolId(
4848
config.getHostname(),
4949
config.getPort(),
50-
config.getHostname(),
50+
config.getUser(),
5151
config.getDatabase(),
5252
dataSourcePoolFactoryIdentifier);
5353
}

0 commit comments

Comments
 (0)