From dc9d6a8a73be2f0d3632cdf5be70ed1a9c07a253 Mon Sep 17 00:00:00 2001 From: 54liuyao <54liuyao@163.com> Date: Thu, 24 Oct 2024 14:59:53 +0800 Subject: [PATCH] fix issue for _isfilled --- source/libs/executor/src/streamtimesliceoperator.c | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/source/libs/executor/src/streamtimesliceoperator.c b/source/libs/executor/src/streamtimesliceoperator.c index 8becadaa1a..b52961c32d 100644 --- a/source/libs/executor/src/streamtimesliceoperator.c +++ b/source/libs/executor/src/streamtimesliceoperator.c @@ -976,7 +976,10 @@ static void setForceWindowCloseFillRule(SStreamFillSupporter* pFillSup, SStreamF } } break; case TSDB_FILL_PREV: { - if (ts >= pFillSup->cur.key) { + if (ts == pFillSup->cur.key) { + pFillInfo->pos = FILL_POS_START; + pFillInfo->needFill = false; + } else if (ts > pFillSup->cur.key) { setFillKeyInfo(ts, ts + 1, &pFillSup->interval, pFillInfo); pFillInfo->pResRow = &pFillSup->cur; } else if (hasPrevWindow(pFillSup)) {