From 0c2079a9636e9c8199d8d908a8faa4b1acfc020a Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Fri, 27 Oct 2023 15:03:21 +0800 Subject: [PATCH] fix(stream): fix deadlock. --- source/libs/stream/src/streamTaskSm.c | 1 + 1 file changed, 1 insertion(+) diff --git a/source/libs/stream/src/streamTaskSm.c b/source/libs/stream/src/streamTaskSm.c index 7f8d8e6740..756880dc4f 100644 --- a/source/libs/stream/src/streamTaskSm.c +++ b/source/libs/stream/src/streamTaskSm.c @@ -189,6 +189,7 @@ int32_t streamTaskHandleEvent(SStreamTaskSM* pSM, EStreamTaskEvent event) { STaskStateTrans* pTrans = streamTaskFindTransform(pSM, event); if (pTrans == NULL) { stWarn("s-task:%s status:%s not allowed handle event:%s", pTask->id.idStr, pSM->current.name, StreamTaskEventList[event].name); + taosThreadMutexUnlock(&pTask->lock); return -1; } else { stDebug("s-task:%s start to handle event:%s, state:%s", pTask->id.idStr, StreamTaskEventList[event].name,