diff --git a/source/libs/executor/src/timewindowoperator.c b/source/libs/executor/src/timewindowoperator.c
index c28bc7e9e8fab86d24b91c64228b262123f9552e..152bd5939dbe8b5bed819f19f26b9c14d9cc4475 100644
--- a/source/libs/executor/src/timewindowoperator.c
+++ b/source/libs/executor/src/timewindowoperator.c
@@ -4330,6 +4330,7 @@ static void clearStreamSessionOperator(SStreamSessionAggOperatorInfo* pInfo) {
     }
   }
   clearDiskbasedBuf(pInfo->streamAggSup.pResultBuf);
+  pInfo->streamAggSup.currentPageId = -1;
 }
 
 static void removeSessionResults(SHashObj* pHashMap, SArray* pWins) {