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

fix ci issue

This commit is contained in:
54liuyao 2024-10-17 17:42:03 +08:00
parent 0e2fe1554b
commit 88c03c8336
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
source/libs/stream/src/streamSliceState.c
View File

@ -33,7 +33,8 @@ int32_t getHashSortRowBuff(SStreamFileState* pFileState, const SWinKey* pKey, vo
SArray* pWinStates = NULL; SArray* pWinStates = NULL;
SSHashObj* pSearchBuff = getSearchBuff(pFileState); SSHashObj* pSearchBuff = getSearchBuff(pFileState);
addArrayBuffIfNotExist(pSearchBuff, pKey->groupId, &pWinStates); code = addArrayBuffIfNotExist(pSearchBuff, pKey->groupId, &pWinStates);
QUERY_CHECK_CODE(code, lino, _end);
// recover // recover
if (taosArrayGetSize(pWinStates) == 0 && needClearDiskBuff(pFileState)) { if (taosArrayGetSize(pWinStates) == 0 && needClearDiskBuff(pFileState)) {
@ -55,7 +56,8 @@ int32_t getHashSortRowBuff(SStreamFileState* pFileState, const SWinKey* pKey, vo
streamStateFreeCur(pCur); streamStateFreeCur(pCur);
} }
addSearchItem(pFileState, pWinStates, pKey); code = addSearchItem(pFileState, pWinStates, pKey);
QUERY_CHECK_CODE(code, lino, _end);
_end: _end:
if (code != TSDB_CODE_SUCCESS) { if (code != TSDB_CODE_SUCCESS) {