fix(stream): unlock when returning.

2023-09-20 15:45:15 +08:00 · 2023-09-20 15:45:15 +08:00 · 1d1d9a1b0b
parent c8ab761d2a
commit 1d1d9a1b0b
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
@ -1640,6 +1640,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);