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;
     }