diff --git a/source/libs/executor/src/timewindowoperator.c b/source/libs/executor/src/timewindowoperator.c
index 6020794429714c08fbc7640fe4ae506d351e6985..cf8d81cbb5df12f1afd672fa6cc13c1075f627cf 100644
--- a/source/libs/executor/src/timewindowoperator.c
+++ b/source/libs/executor/src/timewindowoperator.c
@@ -1645,13 +1645,13 @@ static SSDataBlock* doStreamIntervalAgg(SOperatorInfo* pOperator) {
   while ((pIte = taosHashIterate(pUpdatedMap, pIte)) != NULL) {
     taosArrayPush(pUpdated, pIte);
   }
-  taosHashCleanup(pUpdatedMap);
   taosArraySort(pUpdated, resultrowComparAsc);
 
   finalizeUpdatedResult(pOperator->exprSupp.numOfExprs, pInfo->aggSup.pResultBuf, pUpdated, pSup->rowEntryInfoOffset);
   initMultiResInfoFromArrayList(&pInfo->groupResInfo, pUpdated);
   blockDataEnsureCapacity(pInfo->binfo.pRes, pOperator->resultInfo.capacity);
   removeDeleteResults(pUpdatedMap, pInfo->pDelWins);
+  taosHashCleanup(pUpdatedMap);
   doBuildDeleteResult(pInfo->pDelWins, &pInfo->delIndex, pInfo->pDelRes);
   if (pInfo->pDelRes->info.rows > 0) {
     return pInfo->pDelRes;