fix:[TD-33556] tmq close elegantly to avoid invalid read in TD-32585

2025-01-22 10:59:31 +08:00 · 2025-01-22 10:59:31 +08:00 · dd2a8ecf22
parent 685d06d8aa
commit dd2a8ecf22
1 changed files with 0 additions and 1 deletions
--- a/source/client/src/clientTmq.c
+++ b/source/client/src/clientTmq.c
@ -1649,7 +1649,6 @@ void tmqMgmtClose(void) {
    tmqMgmt.rsetId = -1;
  }
  (void)taosThreadMutexUnlock(&tmqMgmt.lock);
-  (void)taosThreadMutexDestroy(&tmqMgmt.lock);
 }

 tmq_t* tmq_consumer_new(tmq_conf_t* conf, char* errstr, int32_t errstrLen) {