fix(stream): return after get value.

This commit is contained in:
Haojun Liao 2024-07-16 19:42:29 +08:00
parent b29e1c2b0d
commit f3cfd297b8
2 changed files with 3 additions and 2 deletions

View File

@ -5280,8 +5280,8 @@ int32_t tsdbRetrieveDataBlock2(STsdbReader* pReader, SSDataBlock** pBlock, SArra
if (pStatus->composedDataBlock || pReader->info.execMode == READER_EXEC_ROWS) {
// tsdbReaderSuspend2(pReader);
// tsdbReaderResume2(pReader);
*pBlock = pTReader->resBlockInfo.pResBlock;
return TSDB_CODE_SUCCESS;
}
int32_t code = doRetrieveDataBlock(pTReader, pBlock);

View File

@ -120,7 +120,8 @@ endi
if $data01 != 2 then
return -1
endi
if $data02 != 1 then
if $data02 != 1 then
print expect 1 , actual $data02
return -1
endi
if $data03 != 1 then