Merge pull request #26889 from taosdata/fix/syntax

fix(stream): check status before start check-rsp timer.
This commit is contained in:
Haojun Liao 2024-07-31 09:09:18 +08:00 committed by GitHub
commit e4064c3ddd
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 0 deletions

View File

@ -283,6 +283,8 @@ void streamTaskStartMonitorCheckRsp(SStreamTask* pTask) {
// drop procedure already started, not start check downstream now
ETaskStatus s = streamTaskGetStatus(pTask).state;
if (s == TASK_STATUS__DROPPING) {
stDebug("s-task:%s task not in uninit status, status:%s not start monitor check-rsp", pTask->id.idStr,
streamTaskGetStatusStr(s));
streamMutexUnlock(&pInfo->checkInfoLock);
return;
}