From 1bca95bdadd1483d6eebe03a8a2d341cdc81f597 Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao@163.com>
Date: Wed, 30 Nov 2022 09:47:15 +0800
Subject: [PATCH] fix:modify end ts

---
 source/libs/executor/src/tfill.c | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/source/libs/executor/src/tfill.c b/source/libs/executor/src/tfill.c
index 68228f2689..dd00903ae7 100644
--- a/source/libs/executor/src/tfill.c
+++ b/source/libs/executor/src/tfill.c
@@ -1427,7 +1427,7 @@ static void doDeleteFillResult(SOperatorInfo* pOperator) {
           streamStateFreeCur(pCur);
           pCur = streamStateGetAndCheckCur(pOperator->pTaskInfo->streamInfo.pState, &nextKey);
         }
-        endTs = nextKey.ts - 1;
+        endTs = TMAX(ts, nextKey.ts - 1);
         if (code != TSDB_CODE_SUCCESS) {
           break;
         }
-- 
GitLab