fix: save to ext mem file only when sort by row id

This commit is contained in:
slzhou 2024-02-22 11:21:44 +08:00
parent a769bc7217
commit b5bc45c73b
1 changed files with 3 additions and 2 deletions

View File

@ -1423,8 +1423,9 @@ static int32_t sortBlocksToExtSource(SSortHandle* pHandle, SArray* aBlk, SArray*
} }
blockDataCleanup(pHandle->pDataBlock); blockDataCleanup(pHandle->pDataBlock);
} }
if (pHandle->bSortByRowId) {
saveDirtyPagesToExtRowsMemFile(pHandle); saveDirtyPagesToExtRowsMemFile(pHandle);
}
SSDataBlock* pMemSrcBlk = createOneDataBlock(pHandle->pDataBlock, false); SSDataBlock* pMemSrcBlk = createOneDataBlock(pHandle->pDataBlock, false);
doAddNewExternalMemSource(pHandle->pBuf, aExtSrc, pMemSrcBlk, &pHandle->sourceId, aPgId); doAddNewExternalMemSource(pHandle->pBuf, aExtSrc, pMemSrcBlk, &pHandle->sourceId, aPgId);