fix(tsdb): return value if failed.

This commit is contained in:
Haojun Liao 2024-09-23 14:05:36 +08:00
parent 72d44d4207
commit 60308ae844
1 changed files with 4 additions and 2 deletions

View File

@ -3649,12 +3649,14 @@ static int32_t doReadDataFromSttFiles(STsdbReader* pReader, ERetrieveType* pRetu
if (pBlockIter->numOfBlocks > 0) { // there are data blocks existed. if (pBlockIter->numOfBlocks > 0) { // there are data blocks existed.
*pReturnType = TSDB_READ_CONTINUE; *pReturnType = TSDB_READ_CONTINUE;
return code;
} else { // all blocks in data file are checked, let's check the data in stt-files } else { // all blocks in data file are checked, let's check the data in stt-files
code = resetTableListIndex(&pReader->status, pReader->idStr); code = resetTableListIndex(&pReader->status, pReader->idStr);
} if (code) {
return code; return code;
} }
}
}
} }
static int32_t buildBlockFromFiles(STsdbReader* pReader) { static int32_t buildBlockFromFiles(STsdbReader* pReader) {