xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix/TD-31542-fix-case

This commit is contained in:
dmchen 2024-08-28 10:52:03 +00:00
parent 07090ff29d
commit d6f13d838e
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
source/dnode/mnode/impl/src/mndStreamUtil.c
View File

@ -909,8 +909,7 @@ void removeStreamTasksInBuf(SStreamObj *pStream, SStreamExecInfo *pExecNode) {
if (taosHashGetSize(pExecNode->pTaskMap) != taosArrayGetSize(pExecNode->pTaskList)) { if (taosHashGetSize(pExecNode->pTaskMap) != taosArrayGetSize(pExecNode->pTaskList)) {
streamMutexUnlock(&pExecNode->lock); streamMutexUnlock(&pExecNode->lock);
destroyStreamTaskIter(pIter); destroyStreamTaskIter(pIter);
mError("task map size:%d, task list size:%" PRId64 " not equal", taosHashGetSize(pExecNode->pTaskMap), mError("task map size, task list size, not equal");
taosArrayGetSize(pExecNode->pTaskList));
return; return;
} }