a crash generated by dn3_mn1_replica_change.sim
This commit is contained in:
parent
22cb8287b5
commit
acdcd47243
|
@ -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