diff --git a/source/util/src/tqueue.c b/source/util/src/tqueue.c
index 4c80540bed..9ba88b4451 100644
--- a/source/util/src/tqueue.c
+++ b/source/util/src/tqueue.c
@@ -149,8 +149,8 @@ int64_t taosQueueMemorySize(STaosQueue *queue) {
 
 int32_t taosAllocateQitem(int32_t size, EQItype itype, int64_t dataSize, void **item) {
   int64_t alloced = atomic_add_fetch_64(&tsQueueMemoryUsed, size + dataSize);
-  if (itype == RPC_QITEM) {
-    if (alloced > tsQueueMemoryAllowed) {
+  if (alloced > tsQueueMemoryAllowed) {
+    if (itype == RPC_QITEM) {
       uError("failed to alloc qitem, size:%" PRId64 " alloc:%" PRId64 " allowed:%" PRId64, size + dataSize, alloced,
              tsQueueMemoryAllowed);
       (void)atomic_sub_fetch_64(&tsQueueMemoryUsed, size + dataSize);