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