diff --git a/src/backend/distributed/connection/connection_management.c b/src/backend/distributed/connection/connection_management.c index a341221cc..a86deff3f 100644 --- a/src/backend/distributed/connection/connection_management.c +++ b/src/backend/distributed/connection/connection_management.c @@ -345,6 +345,10 @@ StartNodeUserDatabaseConnection(uint32 flags, const char *hostname, int32 port, */ if (!TryToIncrementSharedConnectionCounter(hostname, port)) { + /* do not track the connection anymore */ + dlist_delete(&connection->connectionNode); + pfree(connection); + return NULL; } }