diff --git a/src/backend/distributed/connection/connection_management.c b/src/backend/distributed/connection/connection_management.c
index 577378803..68bd83a00 100644
--- a/src/backend/distributed/connection/connection_management.c
+++ b/src/backend/distributed/connection/connection_management.c
@@ -1490,6 +1490,7 @@ static void
 ResetConnection(MultiConnection *connection)
 {
 	/* reset per-transaction state */
+	CloseRemoteTransaction(connection);
 	ResetRemoteTransaction(connection);
 	ResetShardPlacementAssociation(connection);