fix(query): check for 0 tables in tsdbreader
This commit is contained in:
parent
803762c4e0
commit
fca20668f5
|
@ -3960,6 +3960,9 @@ static bool doTsdbNextDataBlock(STsdbReader* pReader) {
|
||||||
blockDataCleanup(pBlock);
|
blockDataCleanup(pBlock);
|
||||||
|
|
||||||
SReaderStatus* pStatus = &pReader->status;
|
SReaderStatus* pStatus = &pReader->status;
|
||||||
|
if (taosHashGetSize(pStatus->pTableMap) == 0){
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
if (pStatus->loadFromFile) {
|
if (pStatus->loadFromFile) {
|
||||||
int32_t code = buildBlockFromFiles(pReader);
|
int32_t code = buildBlockFromFiles(pReader);
|
||||||
|
@ -3977,8 +3980,6 @@ static bool doTsdbNextDataBlock(STsdbReader* pReader) {
|
||||||
buildBlockFromBufferSequentially(pReader);
|
buildBlockFromBufferSequentially(pReader);
|
||||||
return pBlock->info.rows > 0;
|
return pBlock->info.rows > 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
return false;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
bool tsdbNextDataBlock(STsdbReader* pReader) {
|
bool tsdbNextDataBlock(STsdbReader* pReader) {
|
||||||
|
|
Loading…
Reference in New Issue