From dd15ca61038761d317a64836ce152dbbc86abae6 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Mon, 10 Jul 2023 10:06:21 +0800 Subject: [PATCH] fix(stream): add missing status check. --- 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 89fcecda39..fc0003e20a 100644 --- a/source/libs/stream/src/streamExec.c +++ b/source/libs/stream/src/streamExec.c @@ -407,7 +407,7 @@ int32_t streamExecForAll(SStreamTask* pTask) { break; } - if (status != TASK_STATUS__NORMAL && status != TASK_STATUS__PAUSE) { + if (status != TASK_STATUS__NORMAL && status != TASK_STATUS__PAUSE && status != TASK_STATUS__STOP) { qError("stream task wait for the end of fill history, s-task:%s, status:%d", id, status); taosMsleep(100); } else { -- GitLab