diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c
index 46290c306f5b641c21309b2dcc9c97554c93e723..bf6fcaced7160e0ab748738559c957623444477c 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;