From 23d67933cdcb3c47047fb0a95b737e561c4e5d97 Mon Sep 17 00:00:00 2001 From: 54liuyao <54liuyao@163.com> Date: Wed, 27 Nov 2024 16:52:01 +0800 Subject: [PATCH] add ci --- source/libs/stream/src/streamSliceState.c | 6 ++++-- tests/script/tsim/stream/streamTwaInterpFwcCheckpoint.sim | 6 +++--- 2 files changed, 7 insertions(+), 5 deletions(-) diff --git a/source/libs/stream/src/streamSliceState.c b/source/libs/stream/src/streamSliceState.c index c23537d018..eefe046878 100644 --- a/source/libs/stream/src/streamSliceState.c +++ b/source/libs/stream/src/streamSliceState.c @@ -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); diff --git a/tests/script/tsim/stream/streamTwaInterpFwcCheckpoint.sim b/tests/script/tsim/stream/streamTwaInterpFwcCheckpoint.sim index f983dd3ab5..26be5018c1 100644 --- a/tests/script/tsim/stream/streamTwaInterpFwcCheckpoint.sim +++ b/tests/script/tsim/stream/streamTwaInterpFwcCheckpoint.sim @@ -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