diff --git a/source/client/src/clientTmq.c b/source/client/src/clientTmq.c index 93117c934f..9d53544e1f 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);