fix(stream): unlock when returning.

2023-09-20 15:45:15 +08:00 · 2023-09-20 15:45:15 +08:00 · f5da458c77
parent 36dcdad1a5
commit f5da458c77
1 changed files with 1 additions and 0 deletions
--- a/source/dnode/vnode/src/tq/tq.c
+++ b/source/dnode/vnode/src/tq/tq.c
@ -1653,6 +1653,7 @@ int32_t tqProcessStreamCheckPointSourceReq(STQ* pTq, SRpcMsg* pMsg) {
    SRpcMsg rsp = {0};
    buildCheckpointSourceRsp(&req, &pMsg->info, &rsp, 0);
    tmsgSendRsp(&rsp);   // error occurs
+    taosThreadMutexUnlock(&pTask->lock);
    return TSDB_CODE_SUCCESS;
  }
  streamProcessCheckpointSourceReq(pTask, &req);