fix(query): fix memory leak in last_row query
This commit is contained in:
parent
4b1e8e0cec
commit
877c707ce6
|
@ -590,7 +590,10 @@ static int32_t getNextRowFromFS(void *iter, TSDBROW **ppRow) {
|
||||||
goto _next_fileset;
|
goto _next_fileset;
|
||||||
}
|
}
|
||||||
|
|
||||||
tMapDataReset(&state->blockMap);
|
if (state->blockMap.pData != NULL) {
|
||||||
|
tMapDataClear(&state->blockMap);
|
||||||
|
}
|
||||||
|
|
||||||
code = tsdbReadDataBlk(state->pDataFReader, state->pBlockIdx, &state->blockMap);
|
code = tsdbReadDataBlk(state->pDataFReader, state->pBlockIdx, &state->blockMap);
|
||||||
if (code) goto _err;
|
if (code) goto _err;
|
||||||
|
|
||||||
|
@ -695,6 +698,10 @@ int32_t clearNextRowFromFS(void *iter) {
|
||||||
state->pBlockData = NULL;
|
state->pBlockData = NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (state->blockMap.pData != NULL) {
|
||||||
|
tMapDataClear(&state->blockMap);
|
||||||
|
}
|
||||||
|
|
||||||
return code;
|
return code;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue