From 695de9d3ac313463f5d35604a949f8caa7e3d407 Mon Sep 17 00:00:00 2001
From: liuyao <54liuyao@163.com>
Date: Wed, 17 May 2023 15:19:14 +0800
Subject: [PATCH] fix stream queue mem leak

---
 source/libs/stream/src/stream.c | 1 +
 1 file changed, 1 insertion(+)

diff --git a/source/libs/stream/src/stream.c b/source/libs/stream/src/stream.c
index 635024519e..1a24445af6 100644
--- a/source/libs/stream/src/stream.c
+++ b/source/libs/stream/src/stream.c
@@ -308,6 +308,7 @@ int32_t tAppendDataToInputQueue(SStreamTask* pTask, SStreamQueueItem* pItem) {
              STREAM_TASK_INPUT_QUEUEU_CAPACITY, STREAM_TASK_INPUT_QUEUEU_CAPACITY_IN_SIZE,
              numOfBlocks, size);
       streamDataSubmitDestroy(pSubmitBlock);
+      taosFreeQitem(pSubmitBlock);
       return -1;
     }