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

fix: memory leaks

This commit is contained in:
slzhou 2023-12-08 22:12:24 +08:00
parent 205e3ecf27
commit 92a695cd2f
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/libs/executor/src/scanoperator.c
View File

@ -3241,7 +3241,7 @@ static int32_t saveSourceBlock(STmsSortRowIdInfo* pSortInfo, const SSDataBlock*
, .offset = pSortInfo->dataFileOffset, .length = szBlk}; , .offset = pSortInfo->dataFileOffset, .length = szBlk};
taosLSeekFile(pSortInfo->idxFile, pSortInfo->blkId*sizeof(STmsSortBlockInfo), SEEK_SET); taosLSeekFile(pSortInfo->idxFile, pSortInfo->blkId*sizeof(STmsSortBlockInfo), SEEK_SET);
taosWriteFile(pSortInfo->idxFile, &info, sizeof(info)); taosWriteFile(pSortInfo->idxFile, &info, sizeof(info));
*pSzBlk = szBlk; *pSzBlk = szBlk;
return 0; return 0;
@ -3525,7 +3525,9 @@ int32_t stopRowIdSort(STableMergeScanInfo *pInfo) {
taosCloseFile(&pSort->dataFile); taosCloseFile(&pSort->dataFile);
taosRemoveFile(pSort->dataPath); taosRemoveFile(pSort->dataPath);
taosLRUCacheEraseUnrefEntries(pSort->pBlkInfoCache);
taosLRUCacheCleanup(pSort->pBlkInfoCache); taosLRUCacheCleanup(pSort->pBlkInfoCache);
taosLRUCacheEraseUnrefEntries(pSort->pBlkDataCache);
taosLRUCacheCleanup(pSort->pBlkDataCache); taosLRUCacheCleanup(pSort->pBlkDataCache);
return 0; return 0;
} }