From 5488a8d7f4099b1f66b6c2c7cc41af0b211bc25b Mon Sep 17 00:00:00 2001
From: chenxiaobin <1025221611@qq.com>
Date: Wed, 28 Sep 2022 09:06:39 +0000
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8Dlibpqwalreceiver=E5=86=85?=
 =?UTF-8?q?=E5=AD=98=E6=B3=84=E6=BC=8F=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/gausskernel/storage/replication/libpqwalreceiver.cpp | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/gausskernel/storage/replication/libpqwalreceiver.cpp b/src/gausskernel/storage/replication/libpqwalreceiver.cpp
index 315d48403..26f2f184a 100755
--- a/src/gausskernel/storage/replication/libpqwalreceiver.cpp
+++ b/src/gausskernel/storage/replication/libpqwalreceiver.cpp
@@ -1355,10 +1355,12 @@ bool libpqrcv_receive(int timeout, unsigned char *type, char **buffer, int *len)
 
             /* Verify that there are no more results */
             res = PQgetResult(t_thrd.libwalreceiver_cxt.streamConn);
-            if (res != NULL)
+            if (res != NULL) {
+                PQclear(res);
                 ereport(ERROR,
                         (errmsg("unexpected result after CommandComplete: %s",
                                 PQerrorMessage(t_thrd.libwalreceiver_cxt.streamConn))));
+            }
             *len = -1;
             return false;
         }