diff --git a/source/util/src/tqueue.c b/source/util/src/tqueue.c
index d34839a0ef..bd81267a9d 100644
--- a/source/util/src/tqueue.c
+++ b/source/util/src/tqueue.c
@@ -141,12 +141,14 @@ int32_t taosQueueItemSize(STaosQueue *queue) {
 }
 
 int64_t taosQueueMemorySize(STaosQueue *queue) {
-  if (queue == NULL) return 0;
-
+#if 1
+  return queue->memOfItems;
+#else
   taosThreadMutexLock(&queue->mutex);
   int64_t memOfItems = queue->memOfItems;
   taosThreadMutexUnlock(&queue->mutex);
   return memOfItems;
+#endif
 }
 
 void *taosAllocateQitem(int32_t size, EQItype itype) {
diff --git a/source/util/src/tworker.c b/source/util/src/tworker.c
index 24790bd0e2..f7d4173d3f 100644
--- a/source/util/src/tworker.c
+++ b/source/util/src/tworker.c
@@ -245,6 +245,7 @@ STaosQueue *tWWorkerAllocQueue(SWWorkerPool *pool, void *ahandle, FItems fp) {
   }
 
   uDebug("worker:%s, queue:%p is allocated, ahandle:%p", pool->name, queue, ahandle);
+  code = 0;
 
 _OVER:
   taosThreadMutexUnlock(&pool->mutex);