From 0f9be1033ac8fcbaafc4b854cfa3785a77f22b52 Mon Sep 17 00:00:00 2001 From: slzhou Date: Fri, 5 Jan 2024 19:22:17 +0800 Subject: [PATCH] fix: use page size of sort --- source/libs/executor/src/scanoperator.c | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c index 36e810bd23..b3e6c64953 100644 --- a/source/libs/executor/src/scanoperator.c +++ b/source/libs/executor/src/scanoperator.c @@ -3429,9 +3429,9 @@ int32_t startDurationForGroupTableMergeScan(SOperatorInfo* pOperator) { pInfo->pSortHandle = tsortCreateSortHandle(pInfo->pSortInfo, SORT_BLOCK_TS_MERGE, pInfo->bufPageSize, numOfBufPage, pInfo->pSortInputBlock, pTaskInfo->id.str, 0, 0, 0); int32_t memSize = 512 * 1024 * 1024; - int32_t rowBytes = blockDataGetRowSize(pInfo->pResBlock) + taosArrayGetSize(pInfo->pResBlock->pDataBlock) + sizeof(int32_t); - int32_t pageSize = TMAX(memSize/numOfTable, rowBytes); - tsortSetSortByRowId(pInfo->pSortHandle, pageSize, memSize); + // int32_t rowBytes = blockDataGetRowSize(pInfo->pResBlock) + taosArrayGetSize(pInfo->pResBlock->pDataBlock) + sizeof(int32_t); + // int32_t pageSize = TMAX(memSize/numOfTable, rowBytes); + tsortSetSortByRowId(pInfo->pSortHandle, pInfo->bufPageSize, memSize); } else { pInfo->pSortHandle = tsortCreateSortHandle(pInfo->pSortInfo, SORT_BLOCK_TS_MERGE, pInfo->bufPageSize, numOfBufPage, pInfo->pSortInputBlock, pTaskInfo->id.str, 0, 0, 0);