From c31d64e114c3ef8cd1533031b33df41a914aee1b Mon Sep 17 00:00:00 2001
From: Alex Duan <417921451@qq.com>
Date: Tue, 17 May 2022 21:40:36 +0800
Subject: [PATCH] fix(query): Fill function move set currentKey position

---
 src/query/src/qFill.c | 23 +++++++++++++++++++++--
 1 file changed, 21 insertions(+), 2 deletions(-)

diff --git a/src/query/src/qFill.c b/src/query/src/qFill.c
index 275ffb9ef8..f160a8c91e 100644
--- a/src/query/src/qFill.c
+++ b/src/query/src/qFill.c
@@ -430,8 +430,6 @@ void taosFillSetStartInfo(SFillInfo* pFillInfo, int32_t numOfRows, TSKEY endKey)
   pFillInfo->end = endKey;
   if (!FILL_IS_ASC_FILL(pFillInfo)) {
     pFillInfo->end = taosTimeTruncate(endKey, &pFillInfo->interval, pFillInfo->precision);
-    if (numOfRows > 0)
-      pFillInfo->currentKey = pFillInfo->end;    
   }
 
   pFillInfo->index     = 0;
@@ -451,6 +449,27 @@ void taosFillSetInputDataBlock(SFillInfo* pFillInfo, const SSDataBlock* pInput)
       memcpy(pTag->tagVal, pColData->pData, pCol->col.bytes);  // TODO not memcpy??
     }
   }
+
+  // check currentKey validate
+  if (!FILL_IS_ASC_FILL(pFillInfo)) {
+    int64_t* tsList = (int64_t*) pFillInfo->pData[0];
+    int32_t numOfRows = taosNumOfRemainRows(pFillInfo);
+    int64_t numOfRes = -1;
+    if (numOfRows > 0) {
+      TSKEY lastKey = tsList[pFillInfo->numOfRows - 1];
+      numOfRes = taosTimeCountInterval(
+        lastKey,
+        pFillInfo->currentKey,
+        pFillInfo->interval.sliding,
+        pFillInfo->interval.slidingUnit,
+        pFillInfo->precision);
+      numOfRes += 1;
+      if(numOfRes < numOfRows) {
+        // reset current Key
+        pFillInfo->currentKey = tsList[0];
+      }
+    }
+  }
 }
 
 bool taosFillHasMoreResults(SFillInfo* pFillInfo) {
-- 
GitLab