diff --git a/src/tsdb/src/tsdbRead.c b/src/tsdb/src/tsdbRead.c index 145ee5afa5c705896390d756794ff3eb099c0ed6..e2f1bbcdb9b21562be722458cc73c5a4ef0a62bd 100644 --- a/src/tsdb/src/tsdbRead.c +++ b/src/tsdb/src/tsdbRead.c @@ -2207,6 +2207,10 @@ void tsdbCleanupQueryHandle(TsdbQueryHandleT queryHandle) { size_t size = taosArrayGetSize(pQueryHandle->pTableCheckInfo); for (int32_t i = 0; i < size; ++i) { STableCheckInfo* pTableCheckInfo = taosArrayGet(pQueryHandle->pTableCheckInfo, i); + + tsdbUnRefMemTable(pQueryHandle->pTsdb, pTableCheckInfo->mem); + tsdbUnRefMemTable(pQueryHandle->pTsdb, pTableCheckInfo->imem); + tSkipListDestroyIter(pTableCheckInfo->iter); if (pTableCheckInfo->pDataCols != NULL) {