From 5e0ad7638de9a65df384040a28499ad174c818a2 Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao>
Date: Mon, 11 Dec 2023 19:13:22 +0800
Subject: [PATCH] ignore invalid event window

---
 source/libs/executor/src/streameventwindowoperator.c | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/source/libs/executor/src/streameventwindowoperator.c b/source/libs/executor/src/streameventwindowoperator.c
index 3d38dfffa4..5958562fcd 100644
--- a/source/libs/executor/src/streameventwindowoperator.c
+++ b/source/libs/executor/src/streameventwindowoperator.c
@@ -616,6 +616,10 @@ void streamEventReloadState(SOperatorInfo* pOperator) {
     qDebug("===stream=== reload state. try process result %" PRId64 ", %" PRIu64 ", index:%d", pSeKeyBuf[i].win.skey,
            pSeKeyBuf[i].groupId, i);
     getSessionWindowInfoByKey(pAggSup, pSeKeyBuf + i, &curInfo.winInfo);
+    //event window has been deleted
+    if (!IS_VALID_SESSION_WIN(curInfo.winInfo)) {
+      continue;
+    }
     setEventWindowFlag(pAggSup, &curInfo);
     if (!curInfo.pWinFlag->startFlag || curInfo.pWinFlag->endFlag) {
       continue;