diff --git a/src/system/detail/src/vnodeFile.c b/src/system/detail/src/vnodeFile.c index d1ccbe625cd7e227acf3665e878a1b41c76ce9f1..30d0d96ac00ecdcdce75e86c57b09fce6cd35815 100644 --- a/src/system/detail/src/vnodeFile.c +++ b/src/system/detail/src/vnodeFile.c @@ -1452,7 +1452,8 @@ int vnodeForwardStartPosition(SQuery *pQuery, SCompBlock *pBlock, int32_t slotId int step = QUERY_IS_ASC_QUERY(pQuery) ? 1 : -1; if (pQuery->limit.offset > 0 && pQuery->numOfFilterCols == 0) { - int maxReads = QUERY_IS_ASC_QUERY(pQuery) ? pBlock->numOfPoints - pQuery->pos : pQuery->pos + 1; + assert(pBlock[slotIdx].numOfPoints > pQuery->pos); + int maxReads = QUERY_IS_ASC_QUERY(pQuery) ? pBlock[slotIdx].numOfPoints - pQuery->pos : pQuery->pos + 1; if (pQuery->limit.offset < maxReads) { // start position in current block if (QUERY_IS_ASC_QUERY(pQuery)) {