From 317a7c83c743f312b2d3bf51f7bc87461adffa7f Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Mon, 3 Jul 2023 10:55:45 +0800
Subject: [PATCH] fix(stream): fix message lost bug during pause stream.

---
 source/libs/stream/src/streamExec.c | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c
index 46290c306f..bf6fcaced7 100644
--- a/source/libs/stream/src/streamExec.c
+++ b/source/libs/stream/src/streamExec.c
@@ -381,12 +381,12 @@ int32_t streamExecForAll(SStreamTask* pTask) {
       }
     }
 
-    if (streamTaskShouldStop(&pTask->status)) {
-      if (pInput) {
-        streamFreeQitem(pInput);
-      }
-      return 0;
-    }
+//    if (streamTaskShouldStop(&pTask->status)) {
+//      if (pInput) {
+//        streamFreeQitem(pInput);
+//      }
+//      return 0;
+//    }
 
     if (pInput == NULL) {
       break;