fix:tmq ref err & vg error

This commit is contained in:
wangmm0220 2023-05-18 18:34:42 +08:00
parent 7db9f1e58e
commit 50bdfef7b6
1 changed files with 1 additions and 1 deletions

View File

@ -1390,7 +1390,7 @@ CREATE_MSG_FAIL:
if(pVg){
atomic_store_32(&pVg->vgStatus, TMQ_VG_STATUS__IDLE);
}
taosWLockLatch(&tmq->lock);
taosWUnLockLatch(&tmq->lock);
}
tsem_post(&tmq->rspSem);