xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

test

This commit is contained in:
facetosea 2024-06-13 21:06:58 +08:00
parent a707a2921b
commit 2044cec6ca
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/libs/executor/src/streamtimewindowoperator.c
View File

@ -548,8 +548,8 @@ int32_t setIntervalOutputBuf(void* pState, STimeWindow* win, SRowBuffPos** pResu
// set time window for current result // set time window for current result
res->win = (*win); res->win = (*win);
if(code != TSDB_CODE_SUCCESS) return code; setResultRowInitCtx(res, pCtx, numOfOutput, rowEntryInfoOffset);
return setResultRowInitCtx(res, pCtx, numOfOutput, rowEntryInfoOffset); return code;
} }
bool isDeletedStreamWindow(STimeWindow* pWin, uint64_t groupId, void* pState, STimeWindowAggSupp* pTwSup, bool isDeletedStreamWindow(STimeWindow* pWin, uint64_t groupId, void* pState, STimeWindowAggSupp* pTwSup,