From c99f7cac793867298f8d2fa11e43e487ac47f73b Mon Sep 17 00:00:00 2001
From: shenglian zhou <slzhou@taosdata.com>
Date: Wed, 22 Jun 2022 22:00:52 +0800
Subject: [PATCH] feat: add multiple group tsdb reads to table merge scan

---
 source/libs/executor/src/scanoperator.c | 16 +++++++++-------
 1 file changed, 9 insertions(+), 7 deletions(-)

diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c
index 02c7c67260..a416df4546 100644
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -2212,15 +2212,17 @@ int32_t startGroupTableMergeScan(SOperatorInfo* pOperator) {
   STableMergeScanInfo* pInfo = pOperator->info;
   SExecTaskInfo*       pTaskInfo = pOperator->pTaskInfo;
 
-  size_t  tableListSize = taosArrayGetSize(pInfo->tableListInfo->pTableList);
-  int32_t i = pInfo->tableStartIndex + 1;
-  for (; i < tableListSize; ++i) {
-    STableKeyInfo* tableKeyInfo = taosArrayGet(pInfo->tableListInfo->pTableList, i);
-    if (tableKeyInfo->groupId != pInfo->groupId) {
-      break;
+  {
+    size_t  tableListSize = taosArrayGetSize(pInfo->tableListInfo->pTableList);
+    int32_t i = pInfo->tableStartIndex + 1;
+    for (; i < tableListSize; ++i) {
+      STableKeyInfo* tableKeyInfo = taosArrayGet(pInfo->tableListInfo->pTableList, i);
+      if (tableKeyInfo->groupId != pInfo->groupId) {
+        break;
+      }
     }
+    pInfo->tableEndIndex = i - 1;
   }
-  pInfo->tableEndIndex = i - 1;
 
   int32_t tableStartIdx = pInfo->tableStartIndex;
   int32_t tableEndIdx = pInfo->tableEndIndex;
-- 
GitLab