From 0a414b4934bea7f1275fd983f0b12fd49b50fdd6 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Mon, 13 Jun 2022 13:32:02 +0800 Subject: [PATCH] fix(query): add check for data completed. --- source/client/src/clientMain.c | 5 +++++ source/libs/executor/src/executorimpl.c | 2 +- 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/source/client/src/clientMain.c b/source/client/src/clientMain.c index bc0a7a2258..17a27dd1ce 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 6a93936e65..a3037a16e4 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, -- GitLab