fix(stream): fix deadlock

This commit is contained in:
Haojun Liao 2024-06-21 23:43:25 +08:00
parent 94f3c6ec2d
commit 095510ba41
1 changed files with 1 additions and 0 deletions

View File

@ -805,6 +805,7 @@ static void checkpointReadyMsgSendMonitorFn(void* param, void* tmrId) {
streamMetaReleaseTask(pTask->pMeta, pTask);
return;
}
taosThreadMutexUnlock(&pTask->lock);
taosThreadMutexLock(&pActiveInfo->lock);