From 2044cec6ca4e0f6fcb8fff25db5b996f6bec1d8e Mon Sep 17 00:00:00 2001 From: facetosea <25808407@qq.com> Date: Thu, 13 Jun 2024 21:06:58 +0800 Subject: [PATCH] test --- source/libs/executor/src/streamtimewindowoperator.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/source/libs/executor/src/streamtimewindowoperator.c b/source/libs/executor/src/streamtimewindowoperator.c index 013b0f2f02..2d73cf3cf6 100644 --- a/source/libs/executor/src/streamtimewindowoperator.c +++ b/source/libs/executor/src/streamtimewindowoperator.c @@ -548,8 +548,8 @@ int32_t setIntervalOutputBuf(void* pState, STimeWindow* win, SRowBuffPos** pResu // set time window for current result res->win = (*win); - if(code != TSDB_CODE_SUCCESS) return code; - return setResultRowInitCtx(res, pCtx, numOfOutput, rowEntryInfoOffset); + setResultRowInitCtx(res, pCtx, numOfOutput, rowEntryInfoOffset); + return code; } bool isDeletedStreamWindow(STimeWindow* pWin, uint64_t groupId, void* pState, STimeWindowAggSupp* pTwSup,