From ac2d8f4ca85ccb2350d1ad347ae38414c675025e Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Thu, 1 Feb 2024 13:04:26 +0800
Subject: [PATCH] fix(stream): fix memory leak.

---
 source/client/src/clientImpl.c | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/source/client/src/clientImpl.c b/source/client/src/clientImpl.c
index 71f6a466b9..c1e1da617d 100644
--- a/source/client/src/clientImpl.c
+++ b/source/client/src/clientImpl.c
@@ -971,6 +971,8 @@ void postSubQueryFetchCb(void* param, TAOS_RES* res, int32_t rowNum) {
     tscError("0x%" PRIx64 ", next req ref 0x%" PRIx64 " is not there, reqId:0x%" PRIx64, pRequest->self,
              pRequest->relation.nextRefId, pRequest->requestId);
   }
+
+  blockDataDestroy(pBlock);
 }
 
 void handlePostSubQuery(SSqlCallbackWrapper* pWrapper) {