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

tsdb/cache: close col iter early

This commit is contained in:
Minglei Jin 2024-11-28 10:44:24 +08:00
parent 12b0e70a22
commit c60b6d9912
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/dnode/vnode/src/tsdb/tsdbCache.c
View File

@ -671,6 +671,7 @@ static int32_t tsdbLoadFromImem(SMemTable *imem, TABLEID tid) {
} }
} }
} }
tsdbRowClose(&iter);
// continue to get next row to fill null last col values // continue to get next row to fill null last col values
pMemRow = tsdbImemGetNextRow(&tbIter, pSkyline, &iSkyline); pMemRow = tsdbImemGetNextRow(&tbIter, pSkyline, &iSkyline);
@ -710,9 +711,10 @@ static int32_t tsdbLoadFromImem(SMemTable *imem, TABLEID tid) {
_exit: _exit:
if (code) { if (code) {
tsdbError("vgId:%d %s failed at %s:%d since %s", TD_VID(pTsdb->pVnode), __func__, __FILE__, lino, tstrerror(code)); tsdbError("vgId:%d %s failed at %s:%d since %s", TD_VID(pTsdb->pVnode), __func__, __FILE__, lino, tstrerror(code));
tsdbRowClose(&iter);
} }
tsdbRowClose(&iter);
taosArrayClear(ctxArray); taosArrayClear(ctxArray);
// destroy any allocated resource // destroy any allocated resource
tSimpleHashCleanup(iColHash); tSimpleHashCleanup(iColHash);