From a80f382c5d85b497371cf0bcc84c79daa7ed2ead Mon Sep 17 00:00:00 2001
From: dapan1121 <wpan@taosdata.com>
Date: Fri, 21 Oct 2022 17:00:11 +0800
Subject: [PATCH] fix: fix tsc query memory leak

---
 source/libs/nodes/src/nodesUtilFuncs.c | 14 +++-----------
 1 file changed, 3 insertions(+), 11 deletions(-)

diff --git a/source/libs/nodes/src/nodesUtilFuncs.c b/source/libs/nodes/src/nodesUtilFuncs.c
index e647438800..aec4d0148a 100644
--- a/source/libs/nodes/src/nodesUtilFuncs.c
+++ b/source/libs/nodes/src/nodesUtilFuncs.c
@@ -190,28 +190,20 @@ int32_t nodesReleaseAllocator(int64_t allocatorId) {
     return TSDB_CODE_SUCCESS;
   }
 
-  SNodeAllocator* pAllocator = taosAcquireRef(g_allocatorReqRefPool, allocatorId);
-  if (NULL == pAllocator) {
-    return terrno;
-  }
-
-  int32_t code = taosThreadMutexTryLock(&pAllocator->mutex);
-  if (EBUSY != code) {
+  if (NULL == g_pNodeAllocator) {
     nodesError("allocator id %" PRIx64
                " release failed: The nodesReleaseAllocator function needs to be called after the nodesAcquireAllocator "
                "function is called!",
                allocatorId);
-    if (0 == code) {
-      taosThreadMutexUnlock(&pAllocator->mutex);
-    }
     return TSDB_CODE_FAILED;
   }
-
+  SNodeAllocator* pAllocator = g_pNodeAllocator;
   g_pNodeAllocator = NULL;
   taosThreadMutexUnlock(&pAllocator->mutex);
   return taosReleaseRef(g_allocatorReqRefPool, allocatorId);
 }
 
+
 int64_t nodesMakeAllocatorWeakRef(int64_t allocatorId) {
   if (allocatorId <= 0) {
     return 0;