xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix(tsdb):disable stt statistics.

This commit is contained in:
Haojun Liao 2023-07-20 00:01:30 +08:00
parent ce71b8bbe7
commit bfcc538205
1 changed files with 17 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
source/dnode/vnode/src/tsdb/tsdbMergeTree.c
View File

@ -367,21 +367,21 @@ static bool existsFromSttBlkStatis(const TStatisBlkArray *pStatisBlkArray, uint6
int32_t i = 0; int32_t i = 0;
for (i = 0; i < TARRAY2_SIZE(pStatisBlkArray); ++i) { for (i = 0; i < TARRAY2_SIZE(pStatisBlkArray); ++i) {
SStatisBlk *p = &pStatisBlkArray->data[i]; SStatisBlk *p = &pStatisBlkArray->data[i];
if (p->minTbid.suid == suid) { if (p->minTbid.suid <= suid && p->maxTbid.suid >= suid) {
break; break;
} }
} }
for (; i < TARRAY2_SIZE(pStatisBlkArray); ++i) { // for (; i < TARRAY2_SIZE(pStatisBlkArray); ++i) {
SStatisBlk *p = &pStatisBlkArray->data[i]; // SStatisBlk *p = &pStatisBlkArray->data[i];
if (p->minTbid.uid <= uid && p->maxTbid.uid >= uid) { // if (p->minTbid.uid <= uid && p->maxTbid.uid >= uid) {
break; // break;
} // }
//
if (p->maxTbid.uid < uid) { // if (p->maxTbid.uid < uid) {
break; // break;
} // }
} // }
if (i >= TARRAY2_SIZE(pStatisBlkArray)) { if (i >= TARRAY2_SIZE(pStatisBlkArray)) {
return false; return false;
@ -445,12 +445,12 @@ int32_t tLDataIterOpen2(struct SLDataIter *pIter, SSttFileReader *pSttFileReader
tsdbDebug("load the stt file info completed, elapsed time:%.2fms, %s", el, idStr); tsdbDebug("load the stt file info completed, elapsed time:%.2fms, %s", el, idStr);
} }
bool exists = existsFromSttBlkStatis(pBlockLoadInfo->pSttStatisBlkArray, suid, uid, pIter->pReader); // bool exists = existsFromSttBlkStatis(pBlockLoadInfo->pSttStatisBlkArray, suid, uid, pIter->pReader);
if (!exists) { // if (!exists) {
pIter->iSttBlk = -1; // pIter->iSttBlk = -1;
pIter->pSttBlk = NULL; // pIter->pSttBlk = NULL;
return TSDB_CODE_SUCCESS; // return TSDB_CODE_SUCCESS;
} // }
// find the start block, actually we could load the position to avoid repeatly searching for the start position when // find the start block, actually we could load the position to avoid repeatly searching for the start position when
// the skey is updated. // the skey is updated.