From 8f4da7f308efd4bc6d1642c505785940c261e534 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Sat, 18 May 2024 23:11:18 +0800 Subject: [PATCH] fix(query): fix bugs caused by refactor. --- source/libs/executor/src/exchangeoperator.c | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/source/libs/executor/src/exchangeoperator.c b/source/libs/executor/src/exchangeoperator.c index 4c2976ed94..017332cf2d 100644 --- a/source/libs/executor/src/exchangeoperator.c +++ b/source/libs/executor/src/exchangeoperator.c @@ -717,11 +717,10 @@ int32_t doExtractResultBlocks(SExchangeInfo* pExchangeInfo, SSourceDataInfo* pDa pStart += sizeof(int32_t); ASSERT(compLen <= rawLen && compLen != 0); + pNextStart = pStart + compLen; if (pRetrieveRsp->compressed && (compLen < rawLen)) { int32_t t = tsDecompressString(pStart, compLen, 1, pDataInfo->decompBuf, rawLen, ONE_STAGE_COMP, NULL, 0); ASSERT(t == rawLen); - - pNextStart = pStart + compLen; pStart = pDataInfo->decompBuf; }