diff --git a/source/dnode/mnode/impl/src/mndSync.c b/source/dnode/mnode/impl/src/mndSync.c index 7f6a0397ad..f46f33ac22 100644 --- a/source/dnode/mnode/impl/src/mndSync.c +++ b/source/dnode/mnode/impl/src/mndSync.c @@ -95,7 +95,11 @@ static int32_t mndTransValidatePrepareAction(SMnode *pMnode, STrans *pTrans, STr } _OUT: - taosMemoryFreeClear(pRow); + if (pRow) { + SdbDeleteFp deleteFp = pSdb->deleteFps[pRaw->type]; + if (deleteFp) (*deleteFp)(pSdb, pRow->pObj, false); + taosMemoryFreeClear(pRow); + } return code; }