diff --git a/src/client/src/tscServer.c b/src/client/src/tscServer.c index b477a65e9c4ea476d9ac4db7e10cd0a6ff51ceda..d246a8cd23dbc08055445d1169fda27c1760b0d0 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 a8448d3cea13829e06f24fcdc1258be84a1085b2..ae435efecd77a1e4a4a5ebff82a9280ad5976415 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;