diff --git a/src/backend/distributed/connection/connection_management.c b/src/backend/distributed/connection/connection_management.c index 71af71de5..5dc221e36 100644 --- a/src/backend/distributed/connection/connection_management.c +++ b/src/backend/distributed/connection/connection_management.c @@ -976,10 +976,10 @@ CitusPQFinish(MultiConnection *connection) { if (connection->pgConn != NULL) { - DecrementSharedConnectionCounter(connection->hostname, connection->port); - PQfinish(connection->pgConn); connection->pgConn = NULL; + + DecrementSharedConnectionCounter(connection->hostname, connection->port); } }