diff --git a/src/query/src/qExecutor.c b/src/query/src/qExecutor.c
index c1087db8b7933473465e3d2febc7c014443cd064..9e1534eb24b7c4495c57fd9f0f60b1bd7a20ac1e 100644
--- a/src/query/src/qExecutor.c
+++ b/src/query/src/qExecutor.c
@@ -1347,8 +1347,8 @@ static void doSessionWindowAggImpl(SOperatorInfo* pOperator, SSWindowOperatorInf
       pInfo->start = j;
     } else if (tsList[j] - pInfo->prevTs <= gap) {
       pInfo->curWindow.ekey = tsList[j];
-      //pInfo->prevTs = tsList[j];
       pInfo->numOfRows += 1;
+      pInfo->prevTs = tsList[j];
       if (j == 0 && pInfo->start != 0) {
         pInfo->numOfRows = 1;
         pInfo->start = 0;