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;
         }