fix(stream):fix missing unlock.

2023-09-13 14:11:41 +08:00 · 2023-09-13 14:11:41 +08:00 · d9f6cf3966
parent 7305c8dbe1
commit d9f6cf3966
1 changed files with 1 additions and 0 deletions
--- a/source/libs/stream/src/streamExec.c
+++ b/source/libs/stream/src/streamExec.c
@ -636,6 +636,7 @@ int32_t streamTryExec(SStreamTask* pTask) {
               streamGetTaskStatusStr(pTask->status.taskStatus), pTask->status.schedStatus);
        return 0;
      }
+      taosThreadMutexUnlock(&pTask->lock);
    }
  } else {
    qDebug("s-task:%s already started to exec by other thread, status:%s, sched-status:%d", id,