fix: batch delete logic

This commit is contained in:
kailixu 2023-11-10 15:12:10 +08:00
parent 5fae10bc76
commit b1bca4e1e2
1 changed files with 2 additions and 4 deletions

View File

@ -1893,10 +1893,8 @@ static int32_t vnodeProcessBatchDeleteReq(SVnode *pVnode, int64_t ver, void *pRe
metaReaderDoInit(&mr, pVnode->pMeta, META_READER_NOLOCK);
STsdb *pTsdb = pVnode->pTsdb;
if (deleteReq.level == 1) {
pTsdb = VND_RSMA1(pVnode);
} else {
pTsdb = VND_RSMA2(pVnode);
if (deleteReq.level) {
pTsdb = deleteReq.level == 1 ? VND_RSMA1(pVnode) : VND_RSMA2(pVnode);
}
int32_t sz = taosArrayGetSize(deleteReq.deleteReqs);