diff --git a/src/query/inc/qResultbuf.h b/src/query/inc/qResultbuf.h
index d9da6bb63edfc4f58d39f21216a7897e9e6f4734..e8b3af7ccf7c9e1305adb63c115f6637c8eb1395 100644
--- a/src/query/inc/qResultbuf.h
+++ b/src/query/inc/qResultbuf.h
@@ -37,7 +37,6 @@ typedef struct SDiskbasedResultBuf {
   int32_t   numOfPages;
   int64_t   totalBufSize;
   FILE*     file;
-//  int32_t   fd;                  // data file fd
   int32_t   allocateId;          // allocated page id
   int32_t   incStep;             // minimum allocated pages
   void*     pBuf;                // mmap buffer pointer
diff --git a/src/tsdb/src/tsdbRead.c b/src/tsdb/src/tsdbRead.c
index 3eeca85db7d026e78538e49f2cb1e8e06b025f85..71d3fd9cc40091f78e3e082992de0422a5aadc67 100644
--- a/src/tsdb/src/tsdbRead.c
+++ b/src/tsdb/src/tsdbRead.c
@@ -995,6 +995,8 @@ static void getQualifiedRowsPos(STsdbQueryHandle* pQueryHandle, int32_t startPos
     int32_t remain = endPos - startPos + 1;
     if (remain + numOfExisted > pQueryHandle->outputCapacity) {
       *end = (pQueryHandle->outputCapacity - numOfExisted) + startPos - 1;
+    } else {
+      *end = endPos;
     }
 
     *start = startPos;
@@ -1002,6 +1004,8 @@ static void getQualifiedRowsPos(STsdbQueryHandle* pQueryHandle, int32_t startPos
     int32_t remain = (startPos - endPos) + 1;
     if (remain + numOfExisted > pQueryHandle->outputCapacity) {
       *end = startPos + 1 - (pQueryHandle->outputCapacity - numOfExisted);
+    } else {
+      *end = endPos;
     }
 
     *start = *end;