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

fix(tsdb): adjust invalid assert.

This commit is contained in:
Haojun Liao 2023-06-21 00:12:08 +08:00
parent 413d00db9e
commit a92d16a508
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
source/dnode/vnode/src/tsdb/tsdbRead2.c
View File

@ -899,16 +899,16 @@ static int32_t doLoadBlockIndex(STsdbReader* pReader, SDataFileReader* pFileRead
int32_t i = 0, j = 0; int32_t i = 0, j = 0;
while (i < pBlkArray->size && j < numOfTables) { while (i < pBlkArray->size && j < numOfTables) {
pBrinBlk = &pBlkArray->data[i]; pBrinBlk = &pBlkArray->data[i];
if (pBrinBlk->minTbid.suid > pReader->suid) { // not include the queried table/super table, quit the loop
break;
}
if (pBrinBlk->maxTbid.suid < pReader->suid) { if (pBrinBlk->maxTbid.suid < pReader->suid) {
i += 1; i += 1;
continue; continue;
} }
ASSERT(pBrinBlk->minTbid.suid >= pReader->suid && pBrinBlk->maxTbid.suid <= pReader->suid); if (pBrinBlk->minTbid.suid > pReader->suid) { // not include the queried table/super table, quit the loop
break;
}
ASSERT(pBrinBlk->minTbid.suid <= pReader->suid && pBrinBlk->maxTbid.suid >= pReader->suid);
if (pBrinBlk->minTbid.uid < pList->tableUidList[j]) { if (pBrinBlk->minTbid.uid < pList->tableUidList[j]) {
i += 1; i += 1;