enh(query):init result row size.

This commit is contained in:
Haojun Liao 2023-01-04 17:02:56 +08:00
parent 4237da3c84
commit fbf728f807
1 changed files with 5 additions and 0 deletions

View File

@ -172,6 +172,11 @@ SResultRow* getNewResultRow(SDiskbasedBuf* pResultBuf, int32_t* currentPageId, i
SResultRow* pResultRow = (SResultRow*)((char*)pData + pData->num);
pResultRow->pageId = pageId;
pResultRow->offset = (int32_t)pData->num;
pResultRow->numOfRows = 0;
pResultRow->closed = false;
pResultRow->startInterp = false;
pResultRow->endInterp = false;
*currentPageId = pageId;
pData->num += interBufSize;