diff --git a/src/tsdb/src/tsdbRead.c b/src/tsdb/src/tsdbRead.c index 71d0454893a2b13ecaf24bed2f7a53dc708b8f78..ad3da226f6d5e5baaa04864f92103fbfd82f856a 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; }