fix(query): add check.

This commit is contained in:
Haojun Liao 2022-09-07 13:20:43 +08:00
parent e7149cce3a
commit 74260ebd70
1 changed files with 4 additions and 0 deletions

View File

@ -309,6 +309,10 @@ static void findNextValidRow(SLDataIter *pIter) {
// mostly we only need to find the start position for a given table
if ((((i == 0) && (!pIter->backward)) || (i == pBlockData->nRow - 1 && pIter->backward)) && pBlockData->aUid != NULL) {
i = binarySearchForStartRowIndex((uint64_t*)pBlockData->aUid, pBlockData->nRow, pIter->uid, pIter->backward);
if (i == -1) {
pIter->iRow = -1;
return;
}
}
for (; i < pBlockData->nRow && i >= 0; i += step) {