From 9e62b9d0d21a45e9d284302187867af7560266af Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Mon, 3 Jul 2023 15:33:08 +0800
Subject: [PATCH] fix(stream): fix error in extract data from inputQ.

---
 source/libs/stream/src/streamExec.c | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c
index bfbaed7bf6..847ec3f159 100644
--- a/source/libs/stream/src/streamExec.c
+++ b/source/libs/stream/src/streamExec.c
@@ -347,7 +347,7 @@ static int32_t extractMsgFromInputQ(SStreamTask* pTask, SStreamQueueItem** pInpu
       return TSDB_CODE_SUCCESS;
     }
 
-    if (pInput == NULL) {
+    if (*pInput == NULL) {
       ASSERT((*numOfBlocks) == 0);
       *pInput = qItem;
     } else {
@@ -358,7 +358,8 @@ static int32_t extractMsgFromInputQ(SStreamTask* pTask, SStreamQueueItem** pInpu
         streamQueueProcessFail(pTask->inputQueue);
         return TSDB_CODE_SUCCESS;
       }
-      pInput = newRet;
+
+      *pInput = newRet;
     }
 
     *numOfBlocks += 1;
-- 
GitLab