From 20f7838c8f0c09c56e1d17a8294c9fb6c147d6c2 Mon Sep 17 00:00:00 2001 From: liuyao <54liuyao@163.com> Date: Wed, 12 Apr 2023 13:32:49 +0800 Subject: [PATCH] opt interval final window --- source/libs/executor/src/timewindowoperator.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/libs/executor/src/timewindowoperator.c b/source/libs/executor/src/timewindowoperator.c index c1b3ed647d..eb7c605d69 100644 --- a/source/libs/executor/src/timewindowoperator.c +++ b/source/libs/executor/src/timewindowoperator.c @@ -2140,7 +2140,7 @@ static void rebuildIntervalWindow(SOperatorInfo* pOperator, SArray* pWinArray, S bool isDeletedStreamWindow(STimeWindow* pWin, uint64_t groupId, SStreamState* pState, STimeWindowAggSupp* pTwSup) { if (pTwSup->maxTs != INT64_MIN && pWin->ekey < pTwSup->maxTs - pTwSup->deleteMark) { SWinKey key = {.ts = pWin->skey, .groupId = groupId}; - if (streamStateCheck(pState, &key)) { + if (!hasIntervalWindow(pState, &key)) { return true; } return false; -- GitLab