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

refact task backend

This commit is contained in:
yihaoDeng 2023-10-08 18:16:45 +08:00
parent f49a2cbeb0
commit bffa6387fe
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
source/dnode/vnode/src/tq/tq.c
View File

@ -1792,12 +1792,12 @@ _end:
taosWLockLatch(&pMeta->lock); taosWLockLatch(&pMeta->lock);
terrno = 0; terrno = 0;
int32_t code = streamMetaReopen(pMeta, 0); // int32_t code = streamMetaReopen(pMeta, 0);
if (code != 0) { // if (code != 0) {
tqError("vgId:%d failed to reopen stream meta", vgId); // tqError("vgId:%d failed to reopen stream meta", vgId);
taosWUnLockLatch(&pMeta->lock); // taosWUnLockLatch(&pMeta->lock);
return -1; // return -1;
} // }
if (streamMetaLoadAllTasks(pTq->pStreamMeta) < 0) { if (streamMetaLoadAllTasks(pTq->pStreamMeta) < 0) {
tqError("vgId:%d failed to load stream tasks", vgId); tqError("vgId:%d failed to load stream tasks", vgId);