From 7e21030dfda7fe87a0103cecbfad7ffc53516fe0 Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao>
Date: Mon, 11 Dec 2023 15:16:01 +0800
Subject: [PATCH] set event window rows

---
 source/libs/executor/src/streameventwindowoperator.c | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/source/libs/executor/src/streameventwindowoperator.c b/source/libs/executor/src/streameventwindowoperator.c
index 3d38dfffa4..9371bc4a3a 100644
--- a/source/libs/executor/src/streameventwindowoperator.c
+++ b/source/libs/executor/src/streameventwindowoperator.c
@@ -176,7 +176,7 @@ int32_t updateEventWindowInfo(SStreamAggSupporter* pAggSup, SEventWindowInfo* pW
 
   for (int32_t i = start; i < rows; ++i) {
     if (pTsData[i] >= maxTs) {
-      return i - 1 - start;
+      return i - start;
     }
 
     if (pWin->skey > pTsData[i]) {