From 0fd4f3b5197df370ac3df41b65f8ec188761672e Mon Sep 17 00:00:00 2001
From: Liu Jicong <liujicong@qq.com>
Date: Fri, 8 Jul 2022 23:05:32 +0800
Subject: [PATCH] fix(tmq): invalid free

---
 source/dnode/vnode/src/tq/tq.c | 13 ++++++++++++-
 1 file changed, 12 insertions(+), 1 deletion(-)

diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c
index d60a1026de..4fcc47b0ad 100644
--- a/source/dnode/vnode/src/tq/tq.c
+++ b/source/dnode/vnode/src/tq/tq.c
@@ -299,10 +299,21 @@ int32_t tqProcessPollReq(STQ* pTq, SRpcMsg* pMsg, int32_t workerId) {
         SMqDataRsp dataRsp = {0};
         tqInitDataRsp(&dataRsp, pReq, pHandle->execHandle.subType);
         dataRsp.rspOffset = fetchOffsetNew;
+        code = 0;
         if (tqSendDataRsp(pTq, pMsg, pReq, &dataRsp) < 0) {
           code = -1;
         }
-        goto OVER;
+        taosArrayDestroy(dataRsp.blockDataLen);
+        taosArrayDestroyP(dataRsp.blockData, (FDelete)taosMemoryFree);
+
+        if (dataRsp.withSchema) {
+          taosArrayDestroyP(dataRsp.blockSchema, (FDelete)tDeleteSSchemaWrapper);
+        }
+
+        if (dataRsp.withTbName) {
+          taosArrayDestroyP(dataRsp.blockTbName, (FDelete)taosMemoryFree);
+        }
+        return code;
       } else if (reqOffset.type == TMQ_OFFSET__RESET_NONE) {
         tqError("tmq poll: subkey %s, no offset committed for consumer %ld in vg %d, subkey %s, reset none failed",
                 pHandle->subKey, consumerId, TD_VID(pTq->pVnode), pReq->subKey);