fix: add time window boundary check before interpolation

1afbde7d · Ganlin Zhao · c1fa979f · 1afbde7d
显示空白变更内容
内联并排

Showing with 4 addition and 0 deletion

source/libs/executor/src/timesliceoperator.c source/libs/executor/src/timesliceoperator.c +4 -0

未找到文件。
--- a/source/libs/executor/src/timesliceoperator.c
+++ b/source/libs/executor/src/timesliceoperator.c
@@ -848,6 +848,10 @@ static void doHandleTimeslice(SOperatorInfo* pOperator, SSDataBlock* pBlock) {
  bool                    ignoreNull = getIgoreNullRes(pSup);
  int32_t                 order = TSDB_ORDER_ASC;
+  if (checkWindowBoundReached(pSliceInfo)) {
+    return;
+  }
  int32_t code = initKeeperInfo(pSliceInfo, pBlock, &pOperator->exprSupp);
  if (code != TSDB_CODE_SUCCESS) {
    T_LONG_JMP(pTaskInfo->env, code);