From 3aba49e72ae00bc669fdbb4d4df0781549227fe7 Mon Sep 17 00:00:00 2001
From: Alex Duan <417921451@qq.com>
Date: Tue, 8 Feb 2022 14:05:18 +0800
Subject: [PATCH] [TD-13349]<fix>(query): master->calc skip offset in
 tsdbRead.c ignore read rows

---
 src/tsdb/src/tsdbRead.c | 32 ++++++++++++++++++--------------
 1 file changed, 18 insertions(+), 14 deletions(-)

diff --git a/src/tsdb/src/tsdbRead.c b/src/tsdb/src/tsdbRead.c
index e7c7b9614e..980caea1f3 100644
--- a/src/tsdb/src/tsdbRead.c
+++ b/src/tsdb/src/tsdbRead.c
@@ -1159,6 +1159,8 @@ static int32_t offsetSkipBlock(STsdbQueryHandle* q, SBlockInfo* pBlockInfo, int6
             q->frows += pBlock->numOfRows; // maybe have some row in memroy
           }
         } else {
+          // already read rows belong to forbid skip rows -> frows
+          q->frows += pBlock->numOfRows;          
           // the remainder be put to pArray
           if(pArray == NULL)
               pArray = taosArrayInit(1, sizeof(SRange));
@@ -1225,22 +1227,24 @@ static int32_t offsetSkipBlock(STsdbQueryHandle* q, SBlockInfo* pBlockInfo, int6
           q->frows += pBlock->numOfRows; // maybe have some row in memroy
         }
       } else {
-          // the remainder be put to pArray
-          if(pArray == NULL)
-              pArray = taosArrayInit(1, sizeof(SRange));
-          if(range.from == -1) {
+        // already read rows belong to forbid skip rows -> frows
+        q->frows += pBlock->numOfRows;        
+        // the remainder be put to pArray
+        if(pArray == NULL)
+            pArray = taosArrayInit(1, sizeof(SRange));
+        if(range.from == -1) {
+          range.from = i;
+        } else {
+          if(range.to - 1 != i) {
+            // add the previous
+            taosArrayPush(pArray, &range);
             range.from = i;
-          } else {
-            if(range.to - 1 != i) {
-              // add the previous
-              taosArrayPush(pArray, &range);
-              range.from = i;
-            }
           }
-          range.to = 0;
-          taosArrayPush(pArray, &range);
-          range.from = -1;
-          break;
+        }
+        range.to = 0;
+        taosArrayPush(pArray, &range);
+        range.from = -1;
+        break;
       }
     }
 
-- 
GitLab