diff --git a/src/tsdb/src/tsdbRead.c b/src/tsdb/src/tsdbRead.c index 71d0454893..ad3da226f6 100644 --- a/src/tsdb/src/tsdbRead.c +++ b/src/tsdb/src/tsdbRead.c @@ -1466,8 +1466,8 @@ static int tsdbReadRowsFromCache(SSkipListIterator* pIter, STable* pTable, TSKEY } } - numOfRows++; - if (numOfRows >= maxRowsToRead) { + if (++numOfRows >= maxRowsToRead) { + tSkipListIterNext(pIter); break; }