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

add ci

This commit is contained in:
54liuyao 2024-11-27 16:52:01 +08:00
parent d1f8f383fb
commit 23d67933cd
2 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -65,7 +65,8 @@ int32_t getHashSortRowBuff(SStreamFileState* pFileState, const SWinKey* pKey, vo
// recover
if (taosArrayGetSize(pWinStates) == 0 && needClearDiskBuff(pFileState)) {
recoverSearchBuff(pFileState, pWinStates, pKey->groupId);
code = recoverSearchBuff(pFileState, pWinStates, pKey->groupId);
QUERY_CHECK_CODE(code, lino, _end);
}
code = addSearchItem(pFileState, pWinStates, pKey);
@ -222,7 +223,8 @@ int32_t getHashSortPrevRow(SStreamFileState* pFileState, const SWinKey* pKey, SW
// recover
if (taosArrayGetSize(pWinStates) == 0 && needClearDiskBuff(pFileState)) {
recoverSearchBuff(pFileState, pWinStates, pKey->groupId);
code = recoverSearchBuff(pFileState, pWinStates, pKey->groupId);
QUERY_CHECK_CODE(code, lino, _end);
}
int32_t size = taosArrayGetSize(pWinStates);

6
tests/script/tsim/stream/streamTwaInterpFwcCheckpoint.sim
View File

@ -161,8 +161,8 @@ if $loop_count == 20 then
return -1
endi
print select * from streamt1;
sql select * from streamt1;
print select * from streamt1 order by 1;
sql select * from streamt1 order by 1;
print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 $data14
@ -171,7 +171,7 @@ print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 $data54
if $data02 != 10 then
if $data12 != 10 then
goto loop2
endi