fix(query): set correct sort buffer format

2022-07-15 20:56:29 +08:00 · 2022-07-15 20:56:29 +08:00 · e840cdaaac
parent 50aa7f9cfa
commit e840cdaaac
1 changed files with 1 additions and 1 deletions
--- a/source/libs/executor/src/tsort.c
+++ b/source/libs/executor/src/tsort.c
@ -621,7 +621,7 @@ static int32_t createInitialSources(SSortHandle* pHandle) {
      pHandle->sortElapsed += el;

      // All sorted data can fit in memory, external memory sort is not needed. Return to directly
-      if (size <= sortBufSize) {
+      if (size <= sortBufSize && pHandle->pBuf == NULL) {
        pHandle->cmpParam.numOfSources = 1;
        pHandle->inMemSort = true;