other: merge main.

10692fde · Haojun Liao · afc384be · 10692fde
隐藏空白更改
内联并排

Showing with 3 addition and 1 deletion

source/libs/stream/src/streamExec.c source/libs/stream/src/streamExec.c +3 -1

未找到文件。
--- a/source/libs/stream/src/streamExec.c
+++ b/source/libs/stream/src/streamExec.c
@@ -77,9 +77,11 @@ static int32_t streamTaskExecImpl(SStreamTask* pTask, SStreamQueueItem* pItem, i

  int32_t size = 0;
  int32_t numOfBlocks = 0;
-  SArray* pRes = taosArrayInit(0, sizeof(SSDataBlock));
+  SArray* pRes = NULL;

  while (1) {
+    pRes = taosArrayInit(4, sizeof(SSDataBlock));
+
    if (streamTaskShouldStop(&pTask->status)) {
      taosArrayDestroy(pRes); // memory leak
      return 0;