From 71c3c710e6db673658a5ead9b455166e28a8a5ab Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Tue, 15 Aug 2023 14:23:20 +0800
Subject: [PATCH] fix(stream): continue process when met with trans-state msg.

---
 source/libs/stream/src/streamExec.c | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c
index 6e6f23be01..02bbce6485 100644
--- 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) {