fix(stream): remove invalid free.

d9cc9f21 · Haojun Liao · 937f67f0 · d9cc9f21
隐藏空白更改
内联并排

Showing with 0 addition and 1 deletion

source/libs/stream/src/stream.c source/libs/stream/src/stream.c +0 -1

未找到文件。
--- a/source/libs/stream/src/stream.c
+++ b/source/libs/stream/src/stream.c
@@ -322,7 +322,6 @@ int32_t tAppendDataToInputQueue(SStreamTask* pTask, SStreamQueueItem* pItem) {
    int32_t code = taosWriteQitem(pTask->inputQueue->queue, pItem);
    if (code != TSDB_CODE_SUCCESS) {
      destroyStreamDataBlock((SStreamDataBlock*) pItem);
-      taosFreeQitem(pItem);
      return code;
    }
  } else if (type == STREAM_INPUT__CHECKPOINT) {