From 7a92eb6049f6118be360ed2bd99791e758d2a483 Mon Sep 17 00:00:00 2001 From: shenglian zhou Date: Tue, 11 Jan 2022 10:08:09 +0800 Subject: [PATCH] (query):invalid table schema version processing --- src/client/src/tscServer.c | 2 +- src/query/src/queryMain.c | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/client/src/tscServer.c b/src/client/src/tscServer.c index b477a65e9c..d246a8cd23 100644 --- a/src/client/src/tscServer.c +++ b/src/client/src/tscServer.c @@ -524,7 +524,7 @@ void tscProcessMsgFromServer(SRpcMsg *rpcMsg, SRpcEpSet *pEpSet) { bool shouldFree = tscShouldBeFreed(pSql); - if (rpcMsg->code != TSDB_CODE_TSC_INVALID_SCHEMA_VERSION && rpcMsg->code != TSDB_CODE_TSC_ACTION_IN_PROGRESS) { + if (rpcMsg->code != TSDB_CODE_TSC_ACTION_IN_PROGRESS) { if (rpcMsg->code != TSDB_CODE_SUCCESS) { pRes->code = rpcMsg->code; } diff --git a/src/query/src/queryMain.c b/src/query/src/queryMain.c index a8448d3cea..ae435efecd 100644 --- a/src/query/src/queryMain.c +++ b/src/query/src/queryMain.c @@ -422,7 +422,7 @@ int32_t qDumpRetrieveResult(qinfo_t qinfo, SRetrieveTableRsp **pRsp, int32_t *co 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