From 4128c5653c718b93de8990f13b4bea6cf794f354 Mon Sep 17 00:00:00 2001
From: wangmm0220 <wangmm0220@gmail.com>
Date: Mon, 30 Jan 2023 17:23:04 +0800
Subject: [PATCH] fix:error in tmq for taosx

---
 source/dnode/vnode/src/tq/tqRead.c | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/source/dnode/vnode/src/tq/tqRead.c b/source/dnode/vnode/src/tq/tqRead.c
index e6d81f5b10..12f7af3a71 100644
--- a/source/dnode/vnode/src/tq/tqRead.c
+++ b/source/dnode/vnode/src/tq/tqRead.c
@@ -671,7 +671,7 @@ int32_t tqRetrieveDataBlock2(SSDataBlock* pBlock, STqReader* pReader, SSubmitTbD
           sourceIdx++;
         } else if (pCol->cid == pColData->info.colId) {
           for (int32_t i = 0; i < pCol->nVal; i++) {
-            tColDataGetValue(pCol, sourceIdx, &colVal);
+            tColDataGetValue(pCol, i, &colVal);
 #if 0
             void* val = NULL;
             if (IS_STR_DATA_TYPE(colVal.type)) {
@@ -711,7 +711,6 @@ int32_t tqRetrieveDataBlock2(SSDataBlock* pBlock, STqReader* pReader, SSubmitTbD
 
       for (int32_t i = 0; i < numOfRows; i++) {
         SRow*   pRow = taosArrayGetP(pRows, i);
-        int32_t targetIdx = 0;
         int32_t sourceIdx = 0;
 
         for (int32_t j = 0; j < colActual; j++) {
@@ -744,7 +743,6 @@ int32_t tqRetrieveDataBlock2(SSDataBlock* pBlock, STqReader* pReader, SSubmitTbD
               }
 
               sourceIdx++;
-              targetIdx++;
               break;
             } else {
               ASSERT(0);