From f120a62434aa2255d383f867567ac141a7cb13ce Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Wed, 8 May 2024 16:37:31 +0800 Subject: [PATCH] refactor: do some internal refactor. --- source/libs/executor/src/tsort.c | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/source/libs/executor/src/tsort.c b/source/libs/executor/src/tsort.c index b1688755e6..6fe7e73f77 100644 --- a/source/libs/executor/src/tsort.c +++ b/source/libs/executor/src/tsort.c @@ -1553,7 +1553,7 @@ static int32_t sortBlocksToExtSource(SSortHandle* pHandle, SArray* aBlk, SArray* blockDataCleanup(pHandle->pDataBlock); blkPgSz = pgHeaderSz; incBlock = (pHandle->bSortByRowId) ? pHandle->pDataBlock : minBlk; - bufInc = getPageBufIncForRow(incBlock, minRow, pHandle->pDataBlock->info.rows); + bufInc = getPageBufIncForRow(incBlock, minRow, 0); if ((pHandle->mergeLimit != -1) && (nMergedRows >= pHandle->mergeLimit)) { mergeLimitReached = true; @@ -1573,6 +1573,7 @@ static int32_t sortBlocksToExtSource(SSortHandle* pHandle, SArray* aBlk, SArray* } blkPgSz += bufInc; + ASSERT(blkPgSz == blockDataGetSize(pHandle->pDataBlock)); ++nRows;