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