fix(stream): fix message lost bug during pause stream.

317a7c83 · Haojun Liao · c24a7f64 · 317a7c83
显示空白变更内容
内联并排

Showing with 6 addition and 6 deletion

source/libs/stream/src/streamExec.c source/libs/stream/src/streamExec.c +6 -6

未找到文件。
--- 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 (streamTaskShouldStop(&pTask->status)) {
-      if (pInput) {
+//      if (pInput) {
-        streamFreeQitem(pInput);
+//        streamFreeQitem(pInput);
-      }
+//      }
-      return 0;
+//      return 0;
-    }
+//    }
    if (pInput == NULL) {
      break;