From 78911a68ae27974e4aee054c81e2ea6170e3e79f Mon Sep 17 00:00:00 2001
From: wangmm0220 <wangmm0220@gmail.com>
Date: Mon, 10 Feb 2025 09:09:12 +0800
Subject: [PATCH] fix:do not release tmq to avoid invalid read/write when
 process quit

---
 source/client/src/clientTmq.c | 5 -----
 1 file changed, 5 deletions(-)

diff --git a/source/client/src/clientTmq.c b/source/client/src/clientTmq.c
index 007a23720c..86458024a5 100644
--- a/source/client/src/clientTmq.c
+++ b/source/client/src/clientTmq.c
@@ -1638,11 +1638,6 @@ void tmqMgmtClose(void) {
         break;
       }
       atomic_store_8(&tmq->status, TMQ_CONSUMER_STATUS__CLOSED);
-
-      if (taosRemoveRef(tmqMgmt.rsetId, tmq->refId) != 0) {
-        qWarn("taosRemoveRef tmq refId:%" PRId64 " failed, error:%s", refId, tstrerror(terrno));
-      }
-
       tmq = taosIterateRef(tmqMgmt.rsetId, refId);
     }
     taosCloseRef(tmqMgmt.rsetId);