[td-225] fix bugs in retrieve error.
This commit is contained in:
parent
9f940295d6
commit
5aff8962a4
|
@ -1795,14 +1795,17 @@ bool tsdbNextDataBlock(TsdbQueryHandleT* pHandle) {
|
||||||
|
|
||||||
if (pQueryHandle->checkFiles) {
|
if (pQueryHandle->checkFiles) {
|
||||||
bool exists = true;
|
bool exists = true;
|
||||||
|
|
||||||
int32_t code = getDataBlocksInFiles(pQueryHandle, &exists);
|
int32_t code = getDataBlocksInFiles(pQueryHandle, &exists);
|
||||||
if (code != TSDB_CODE_SUCCESS) {
|
if (code != TSDB_CODE_SUCCESS) {
|
||||||
return code;
|
pQueryHandle->activeIndex = 0;
|
||||||
|
pQueryHandle->checkFiles = false;
|
||||||
|
|
||||||
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (exists) {
|
if (exists) {
|
||||||
elapsedTime = taosGetTimestampUs() - stime;
|
pQueryHandle->cost.checkForNextTime += (taosGetTimestampUs() - stime);
|
||||||
pQueryHandle->cost.checkForNextTime += elapsedTime;
|
|
||||||
return exists;
|
return exists;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue