diff --git a/source/client/src/clientMain.c b/source/client/src/clientMain.c
index bc0a7a22589af79f1e984fc1773b62f3eb785939..17a27dd1ce909bfec9da3ab29603d65416084313 100644
--- a/source/client/src/clientMain.c
+++ b/source/client/src/clientMain.c
@@ -824,6 +824,11 @@ void taos_fetch_raw_block_a(TAOS_RES* res, __taos_async_fn_t fp, void* param) {
   SRequestObj *pRequest = res;
 
   pRequest->body.resInfo.convertUcs4 = false;
+
+  SReqResultInfo *pResultInfo = &pRequest->body.resInfo;
+
+  // set the current block is all consumed
+  pResultInfo->current = pResultInfo->numOfRows;
   taos_fetch_rows_a(res, fp, param);
 }
 
diff --git a/source/libs/executor/src/executorimpl.c b/source/libs/executor/src/executorimpl.c
index 6a93936e656fcec9201bfcabc315e0c5ee944c56..a3037a16e42b5bd429de9a54392bbfb96d472e3c 100644
--- a/source/libs/executor/src/executorimpl.c
+++ b/source/libs/executor/src/executorimpl.c
@@ -4553,7 +4553,7 @@ static SExecTaskInfo* createExecTaskInfo(uint64_t queryId, uint64_t taskId, EOPT
 }
 
 static tsdbReaderT doCreateDataReader(STableScanPhysiNode* pTableScanNode, SReadHandle* pHandle,
-                                      STableListInfo* pTableGroupInfo, uint64_t queryId, uint64_t taskId,
+                                      STableListInfo* pTableListInfo, uint64_t queryId, uint64_t taskId,
                                       SNode* pTagCond);
 
 static int32_t getTableList(void* metaHandle, int32_t tableType, uint64_t tableUid, STableListInfo* pListInfo,