Skip to content

Commit 533072b

Browse files
authored
[FLINK-38847][postgres] Update PostgresConnectionPoolFactory#getPoolId method to use username correctly. (apache#4204)
1 parent 44fb79f commit 533072b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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)