From 7c35dce7fc6e7d7fce7917308793782f87f36013 Mon Sep 17 00:00:00 2001 From: slzhou Date: Wed, 6 Jul 2022 18:31:54 +0800 Subject: [PATCH] fix: add condition to window operator --- source/libs/planner/src/planPhysiCreater.c | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/source/libs/planner/src/planPhysiCreater.c b/source/libs/planner/src/planPhysiCreater.c index 7ec3af31b2..f2e7151a10 100644 --- a/source/libs/planner/src/planPhysiCreater.c +++ b/source/libs/planner/src/planPhysiCreater.c @@ -1067,6 +1067,10 @@ static int32_t createWindowPhysiNodeFinalize(SPhysiPlanContext* pCxt, SNodeList* } } + if (TSDB_CODE_SUCCESS == code) { + code = setConditionsSlotId(pCxt, (const SLogicNode*)pWindowLogicNode, (SPhysiNode*)pWindow); + } + pWindow->triggerType = pWindowLogicNode->triggerType; pWindow->watermark = pWindowLogicNode->watermark; pWindow->igExpired = pWindowLogicNode->igExpired;