diff --git a/source/dnode/vnode/src/vnd/vnodeSvr.c b/source/dnode/vnode/src/vnd/vnodeSvr.c index b5e049b692..8fcd64373f 100644 --- a/source/dnode/vnode/src/vnd/vnodeSvr.c +++ b/source/dnode/vnode/src/vnd/vnodeSvr.c @@ -2060,12 +2060,14 @@ static int32_t vnodeProcessDeleteReq(SVnode *pVnode, int64_t ver, void *pReq, in tDecoderInit(pCoder, pReq, len); tDecodeDeleteRes(pCoder, pRes); - for (int32_t iUid = 0; iUid < taosArrayGetSize(pRes->uidList); iUid++) { - uint64_t uid = *(uint64_t *)taosArrayGet(pRes->uidList, iUid); - code = tsdbDeleteTableData(pVnode->pTsdb, ver, pRes->suid, uid, pRes->skey, pRes->ekey); - if (code) goto _err; - code = metaUpdateChangeTimeWithLock(pVnode->pMeta, uid, pRes->ctimeMs); - if (code) goto _err; + if (pRes->affectedRows > 0) { + for (int32_t iUid = 0; iUid < taosArrayGetSize(pRes->uidList); iUid++) { + uint64_t uid = *(uint64_t *)taosArrayGet(pRes->uidList, iUid); + code = tsdbDeleteTableData(pVnode->pTsdb, ver, pRes->suid, uid, pRes->skey, pRes->ekey); + if (code) goto _err; + code = metaUpdateChangeTimeWithLock(pVnode->pMeta, uid, pRes->ctimeMs); + if (code) goto _err; + } } code = tdProcessRSmaDelete(pVnode->pSma, ver, pRes, pReq, len);