fix:lock error

This commit is contained in:
wangmm0220 2023-06-13 18:27:06 +08:00
parent ae09d1d031
commit 8070223aba
1 changed files with 1 additions and 1 deletions

View File

@ -446,7 +446,7 @@ int32_t tqProcessPollPush(STQ* pTq, SRpcMsg* pMsg) {
taosHashClear(pTq->pPushMgr);
}
taosWLockLatch(&pTq->lock);
taosWUnLockLatch(&pTq->lock);
return 0;
}