From 71e676ce52c88092540c11833440bd9a7a957e20 Mon Sep 17 00:00:00 2001 From: shenglian zhou Date: Tue, 11 Jan 2022 10:01:56 +0800 Subject: [PATCH] (query):remove sversion/tversion from SSqlRes and reset retrivets when qDumpRetrieveResult --- src/client/inc/tsclient.h | 2 -- src/query/src/queryMain.c | 3 +++ 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/src/client/inc/tsclient.h b/src/client/inc/tsclient.h index 48cc71bc9f..c5e3cb727f 100644 --- a/src/client/inc/tsclient.h +++ b/src/client/inc/tsclient.h @@ -307,8 +307,6 @@ typedef struct { int32_t row; int16_t numOfCols; int16_t precision; - int32_t sVersion; - int32_t tVersion; bool completed; int32_t code; char * data; diff --git a/src/query/src/queryMain.c b/src/query/src/queryMain.c index 73d0b341d6..a8448d3cea 100644 --- a/src/query/src/queryMain.c +++ b/src/query/src/queryMain.c @@ -420,6 +420,9 @@ int32_t qDumpRetrieveResult(qinfo_t qinfo, SRetrieveTableRsp **pRsp, int32_t *co setQueryStatus(pRuntimeEnv, QUERY_OVER); } + RESET_NUM_OF_RESULTS(&(pQInfo->runtimeEnv)); + pQInfo->lastRetrieveTs = taosGetTimestampMs(); + if ((*pRsp)->compressed && compLen != 0) { int32_t numOfCols = pQueryAttr->pExpr2 ? pQueryAttr->numOfExpr2 : pQueryAttr->numOfOutput; int32_t origSize = pQueryAttr->resultRowSize * s; -- GitLab