refactor(query): set correct buffer pages.

af7f3e32 · Haojun Liao · feebe90a · af7f3e32
隐藏空白更改
内联并排

Showing with 3 addition and 1 deletion

source/libs/executor/src/scanoperator.c source/libs/executor/src/scanoperator.c +3 -1

未找到文件。
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -2303,7 +2303,9 @@ SOperatorInfo* createTableMergeScanOperatorInfo(STableScanPhysiNode* pTableScanN

  int32_t rowSize = pInfo->pResBlock->info.rowSize;
  pInfo->bufPageSize     = getProperSortPageSize(rowSize);
-  pInfo->sortBufSize     = pInfo->bufPageSize * 16;
+
+  // the additional one is reserved for merge result
+  pInfo->sortBufSize     = pInfo->bufPageSize * (taosArrayGetSize(dataReaders) + 1);
  pInfo->hasGroupId      = false;
  pInfo->prefetchedTuple = NULL;