From a73992e12833b4dec874dcab47d28ed314fab4cd Mon Sep 17 00:00:00 2001 From: 54liuyao <54liuyao> Date: Tue, 28 Nov 2023 14:11:19 +0800 Subject: [PATCH] stream event reload state --- 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 9b987ff1a4..8029b9b156 100644 --- a/source/libs/executor/src/streameventwindowoperator.c +++ b/source/libs/executor/src/streameventwindowoperator.c @@ -603,7 +603,7 @@ void streamEventReloadState(SOperatorInfo* pOperator) { pSeKeyBuf[i].groupId, i); getSessionWindowInfoByKey(pAggSup, pSeKeyBuf + i, &curInfo.winInfo); setEventWindowFlag(pAggSup, &curInfo); - if (!curInfo.pWinFlag->startFlag || curInfo.pWinFlag->endFlag) { + if (!curInfo.pWinFlag->startFlag || !curInfo.pWinFlag->endFlag) { continue; }