From fb732be16dc9b48db8a969f9a04b194ed212d546 Mon Sep 17 00:00:00 2001
From: slzhou <shenglian_zhou@163.com>
Date: Wed, 3 Jan 2024 15:09:24 +0800
Subject: [PATCH] fix: change pageSize and buf size

---
 source/libs/executor/src/tsort.c | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/source/libs/executor/src/tsort.c b/source/libs/executor/src/tsort.c
index 714b268008..59146f85a5 100644
--- a/source/libs/executor/src/tsort.c
+++ b/source/libs/executor/src/tsort.c
@@ -1045,7 +1045,6 @@ static void appendToRowIndexDataBlock(SSortHandle* pHandle, SSDataBlock* pSource
 }
 
 static void initRowIdSort(SSortHandle* pHandle) {
-  blockDataDestroy(pHandle->pDataBlock);
 
   SSDataBlock* pSortInput = createDataBlock();
   SColumnInfoData tsCol = createColumnInfoData(TSDB_DATA_TYPE_TIMESTAMP, 8, 1);
@@ -1054,7 +1053,14 @@ static void initRowIdSort(SSortHandle* pHandle) {
   blockDataAppendColInfo(pSortInput, &pageIdCol);
   SColumnInfoData  offsetCol = createColumnInfoData(TSDB_DATA_TYPE_INT, 4, 3);
   blockDataAppendColInfo(pSortInput, &offsetCol);
+
+  blockDataDestroy(pHandle->pDataBlock);
   pHandle->pDataBlock = pSortInput;
+  
+  int32_t  rowSize = blockDataGetRowSize(pHandle->pDataBlock);
+  size_t nCols = taosArrayGetSize(pHandle->pDataBlock->pDataBlock);
+  pHandle->pageSize = getProperSortPageSize(rowSize, nCols);
+  pHandle->numOfPages = 2048;
 
   SBlockOrderInfo* pOrder = taosArrayGet(pHandle->pSortInfo, 0);
   SBlockOrderInfo bi = {0};