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

opti:[TS-4593] transform offset from file to tdb in tmq

This commit is contained in:
wangmm0220 2024-08-05 18:26:47 +08:00
parent a450e8c1f5
commit 591c1acce1
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
source/dnode/vnode/src/tq/tqOffset.c
View File

@ -82,7 +82,11 @@ int32_t tqOffsetRestoreFromFile(STQ* pTq, char* name) {
void *pIter = NULL; void *pIter = NULL;
while ((pIter = taosHashIterate(pTq->pOffset, pIter))) { while ((pIter = taosHashIterate(pTq->pOffset, pIter))) {
STqOffset* pOffset = (STqOffset*)pIter; STqOffset* pOffset = (STqOffset*)pIter;
tqMetaSaveOffset(pTq, pOffset); code = tqMetaSaveOffset(pTq, pOffset);
if(code != 0){
taosHashCancelIterate(pTq->pOffset, pIter);
goto END;
}
} }
END: END: