From b03ca5d4dc01561f3f821f91a24e5b75e11e2c5f Mon Sep 17 00:00:00 2001
From: Jelte Fennema <github-tech@jeltef.nl>
Date: Thu, 2 Feb 2023 13:43:10 +0100
Subject: [PATCH] Better cleanup

---
 src/backend/distributed/executor/adaptive_executor.c | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/backend/distributed/executor/adaptive_executor.c b/src/backend/distributed/executor/adaptive_executor.c
index 8369878b7..f8ac3383c 100644
--- a/src/backend/distributed/executor/adaptive_executor.c
+++ b/src/backend/distributed/executor/adaptive_executor.c
@@ -4222,7 +4222,7 @@ TransactionStateMachine(WorkerSession *session)
 				}
 				else
 				{
-					transaction->transactionState = REMOTE_TRANS_NOT_STARTED;
+					ResetRemoteTransaction(connection);
 				}
 				break;
 			}