fix(stream): continue process when met with trans-state msg.

71c3c710 · Haojun Liao · 0acb00c5 · 71c3c710
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

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

未找到文件。
--- a/source/libs/stream/src/streamExec.c
+++ b/source/libs/stream/src/streamExec.c
@@ -575,7 +575,7 @@ int32_t streamExecForAll(SStreamTask* pTask) {

    if (pInput->type == STREAM_INPUT__TRANS_STATE) {
      streamProcessTranstateBlock(pTask, (SStreamDataBlock*)pInput);
-      return 0;
+      continue;
    }

    if (pTask->info.taskLevel == TASK_LEVEL__SINK) {