fix(query): add check for data completed.

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);
 }
 

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,