From 7fccac5029b2f1d5a6cb17006d1af2a1c16b1d43 Mon Sep 17 00:00:00 2001
From: Liu Jicong <liujicong@qq.com>
Date: Mon, 15 Aug 2022 11:26:50 +0800
Subject: [PATCH] fix(tmq): memory leak in call back

---
 source/client/src/tmq.c | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/source/client/src/tmq.c b/source/client/src/tmq.c
index f32bfbb4f3..bf63e6741d 100644
--- a/source/client/src/tmq.c
+++ b/source/client/src/tmq.c
@@ -381,6 +381,9 @@ int32_t tmqCommitCb(void* param, SDataBuf* pBuf, int32_t code) {
   }
 #endif
 
+  taosMemoryFree(pParam->pOffset);
+  if (pBuf->pData) taosMemoryFree(pBuf->pData);
+
   /*tscDebug("receive offset commit cb of %s on vgId:%d, offset is %" PRId64, pParam->pOffset->subKey, pParam->->vgId,
    * pOffset->version);*/
 
@@ -388,8 +391,6 @@ int32_t tmqCommitCb(void* param, SDataBuf* pBuf, int32_t code) {
   int32_t waitingRspNum = atomic_sub_fetch_32(&pParamSet->waitingRspNum, 1);
   ASSERT(waitingRspNum >= 0);
 
-  taosMemoryFree(pParam);
-
   if (waitingRspNum == 0) {
     // if no more waiting rsp
     if (pParamSet->async) {
@@ -1220,6 +1221,7 @@ END:
   } else {
     taosMemoryFree(pParam);
   }
+  taosMemoryFree(pMsg->pData);
   return code;
 }