From 4235045d72ff3dcc261422e9b6065f6d873c8fb0 Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao>
Date: Tue, 25 Jun 2024 14:36:21 +0800
Subject: [PATCH] adj delete range

---
 source/libs/executor/src/streamfilloperator.c | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/source/libs/executor/src/streamfilloperator.c b/source/libs/executor/src/streamfilloperator.c
index 50cd5eea17..c1a38b66ba 100644
--- a/source/libs/executor/src/streamfilloperator.c
+++ b/source/libs/executor/src/streamfilloperator.c
@@ -790,7 +790,7 @@ static void doDeleteFillFinalize(SOperatorInfo* pOperator) {
   SStreamFillOperatorInfo* pInfo = pOperator->info;
   SStreamFillInfo*         pFillInfo = pInfo->pFillInfo;
   int32_t                  size = taosArrayGetSize(pFillInfo->delRanges);
-  for (; pFillInfo->delIndex < size; pFillInfo->delIndex++) {
+  while (pFillInfo->delIndex < size) {
     STimeRange* range = taosArrayGet(pFillInfo->delRanges, pFillInfo->delIndex);
     if (pInfo->pRes->info.id.groupId != 0 && pInfo->pRes->info.id.groupId != range->groupId) {
       return;
@@ -801,6 +801,7 @@ static void doDeleteFillFinalize(SOperatorInfo* pOperator) {
       getWindowInfoByKey(pAPI, pOperator->pTaskInfo->streamInfo.pState, realEnd, range->groupId, &pInfo->pFillSup->next);
     }
     setDeleteFillValueInfo(range->skey, range->ekey, pInfo->pFillSup, pInfo->pFillInfo);
+    pFillInfo->delIndex++;
     if (pInfo->pFillInfo->needFill) {
       doStreamFillRange(pInfo->pFillInfo, pInfo->pFillSup, pInfo->pRes);
       pInfo->pRes->info.id.groupId = range->groupId;