From a7691aba9c79b5f4f5f2091f6f0671a46d60cecf Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Mon, 8 May 2023 00:24:00 +0800
Subject: [PATCH] fix(stream): set the correct queue item size.

---
 source/util/src/tqueue.c | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/source/util/src/tqueue.c b/source/util/src/tqueue.c
index e2f1d7c033..767b0d7a24 100644
--- a/source/util/src/tqueue.c
+++ b/source/util/src/tqueue.c
@@ -185,7 +185,7 @@ int32_t taosWriteQitem(STaosQueue *queue, void *pItem) {
     queue->tail = pNode;
   }
   queue->numOfItems++;
-  queue->memOfItems += pNode->size;
+  queue->memOfItems += (pNode->size + pNode->dataSize);
   if (queue->qset) atomic_add_fetch_32(&queue->qset->numOfItems, 1);
 
   uTrace("item:%p is put into queue:%p, items:%d mem:%" PRId64, pItem, queue, queue->numOfItems, queue->memOfItems);