From dd15ca61038761d317a64836ce152dbbc86abae6 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Mon, 10 Jul 2023 10:06:21 +0800 Subject: [PATCH 1/3] 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 { From e8eba3175a96d03d1199cb0d906707170c0cdc8b Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Mon, 10 Jul 2023 10:23:05 +0800 Subject: [PATCH 2/3] fix(stream): fix error in checking status. --- 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 fc0003e20a..cecbb8c4df 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 && status != TASK_STATUS__STOP) { + if (status != TASK_STATUS__NORMAL && status != TASK_STATUS__PAUSE && zstatus != TASK_STATUS__STOP) { qError("stream task wait for the end of fill history, s-task:%s, status:%d", id, status); taosMsleep(100); } else { From 9ad5e057512e5e5e5c689e53e1a73495c9b93526 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Mon, 10 Jul 2023 10:24:04 +0800 Subject: [PATCH 3/3] fix(stream): fix error in checking status. --- 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 cecbb8c4df..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 && zstatus != TASK_STATUS__STOP) { + 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 {