diff --git a/source/dnode/mnode/impl/src/mndCompact.c b/source/dnode/mnode/impl/src/mndCompact.c index 2b25f20fda..065a9a327d 100644 --- a/source/dnode/mnode/impl/src/mndCompact.c +++ b/source/dnode/mnode/impl/src/mndCompact.c @@ -708,13 +708,13 @@ static int32_t mndSaveCompactProgress(SMnode *pMnode, int32_t compactId) { if (pDetail->numberFileset == -1 && pDetail->finished == -1) { allFinished = false; - sdbCancelFetch(pMnode->pSdb, pDetail); + sdbCancelFetch(pMnode->pSdb, pIter); sdbRelease(pMnode->pSdb, pDetail); break; } if (pDetail->numberFileset != -1 && pDetail->finished != -1 && pDetail->numberFileset != pDetail->finished) { allFinished = false; - sdbCancelFetch(pMnode->pSdb, pDetail); + sdbCancelFetch(pMnode->pSdb, pIter); sdbRelease(pMnode->pSdb, pDetail); break; }