From b1bca4e1e2e89fddfd2023020679d0f69d93ddff Mon Sep 17 00:00:00 2001 From: kailixu Date: Fri, 10 Nov 2023 15:12:10 +0800 Subject: [PATCH] fix: batch delete logic --- source/dnode/vnode/src/vnd/vnodeSvr.c | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/source/dnode/vnode/src/vnd/vnodeSvr.c b/source/dnode/vnode/src/vnd/vnodeSvr.c index d0c0e5f65e..29db7d602f 100644 --- a/source/dnode/vnode/src/vnd/vnodeSvr.c +++ b/source/dnode/vnode/src/vnd/vnodeSvr.c @@ -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);