From e8617812aef0951d18edfc30d2704ea4165b19c2 Mon Sep 17 00:00:00 2001
From: dmchen <cademfly@hotmail.com>
Date: Fri, 8 Dec 2023 10:17:04 +0000
Subject: [PATCH] update progress rsp

---
 source/dnode/mnode/impl/src/mndCompact.c | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/source/dnode/mnode/impl/src/mndCompact.c b/source/dnode/mnode/impl/src/mndCompact.c
index 08bdac277c..b7160b5bc0 100644
--- a/source/dnode/mnode/impl/src/mndCompact.c
+++ b/source/dnode/mnode/impl/src/mndCompact.c
@@ -473,12 +473,16 @@ static int32_t mndUpdateCompactProgress(SMnode *pMnode, SRpcMsg *pReq, int32_t c
     if (pDetail->compactId == compactId && pDetail->vgId == rsp->vgId && pDetail->dnodeId == rsp->dnodeId) {
       pDetail->newNumberFileset = rsp->numberFileset;
       pDetail->newFinished = rsp->finished;
+
+      sdbRelease(pMnode->pSdb, pDetail);
+
+      return 0;
     }
 
     sdbRelease(pMnode->pSdb, pDetail);
   }
 
-  return 0;
+  return -1;
 }
 
 int32_t mndProcessQueryCompactRsp(SRpcMsg *pReq){
@@ -495,7 +499,11 @@ int32_t mndProcessQueryCompactRsp(SRpcMsg *pReq){
   int32_t       code = -1;
   
 
-  mndUpdateCompactProgress(pMnode, pReq, req.compactId, &req);
+  if(mndUpdateCompactProgress(pMnode, pReq, req.compactId, &req) != 0){
+    mError("compact:%d, failed to update progress, vgId:%d, dnodeId:%d, numberFileset:%d, finished:%d", 
+        req.compactId, req.vgId, req.dnodeId, req.numberFileset, req.finished);
+    return -1;
+  }
 
   return 0;
 }