fix(stream): fix invalid free.

2023-05-30 18:02:42 +08:00 · 2023-05-30 18:02:42 +08:00 · 937f67f07b
parent e96ed81ec0
commit 937f67f07b
1 changed files with 0 additions and 1 deletions
--- a/source/libs/stream/src/stream.c
+++ b/source/libs/stream/src/stream.c
@ -315,7 +315,6 @@ int32_t tAppendDataToInputQueue(SStreamTask* pTask, SStreamQueueItem* pItem) {
             pTask->id.idStr, STREAM_TASK_INPUT_QUEUEU_CAPACITY, STREAM_TASK_INPUT_QUEUEU_CAPACITY_IN_SIZE, total,
             size);
      destroyStreamDataBlock((SStreamDataBlock*) pItem);
-      taosFreeQitem(pItem);
      return -1;
    }