fix(query): check for null.

This commit is contained in:
Haojun Liao 2024-09-24 18:58:49 +08:00
parent 4e4003c5a7
commit c1333a920d
1 changed files with 3 additions and 0 deletions

View File

@ -279,6 +279,9 @@ static int32_t getSortedBlockData(SSortHandle* pHandle, SSDataBlock* pDataBlock,
} }
TSDB_CHECK_CODE(code, lino, _error); TSDB_CHECK_CODE(code, lino, _error);
if (pTupleHandle == NULL) {
break;
}
code = appendOneRowToDataBlock(p, pTupleHandle); code = appendOneRowToDataBlock(p, pTupleHandle);
QUERY_CHECK_CODE(code, lino, _error); QUERY_CHECK_CODE(code, lino, _error);