fix: add condition to window operator

7c35dce7 · slzhou · 1a70a5f9 · 7c35dce7
隐藏空白更改
内联并排

Showing with 4 addition and 0 deletion

source/libs/planner/src/planPhysiCreater.c source/libs/planner/src/planPhysiCreater.c +4 -0

未找到文件。
--- 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;