diff --git a/source/dnode/mnode/impl/src/mndSubscribe.c b/source/dnode/mnode/impl/src/mndSubscribe.c
index 4824f2d06b5eca07659e58e2903bc175a3ae689f..eca59260ccf5a6f3d97968da6204394a58161a36 100644
--- a/source/dnode/mnode/impl/src/mndSubscribe.c
+++ b/source/dnode/mnode/impl/src/mndSubscribe.c
@@ -356,7 +356,7 @@ static int32_t mndProcessDoRebalanceMsg(SMnodeMsg *pMsg) {
           SMqConsumerObj *pRebConsumer = mndAcquireConsumer(pMnode, pSubConsumer->consumerId);
           pRebConsumer->epoch++;
           SSdbRaw* pConsumerRaw = mndConsumerActionEncode(pRebConsumer);
-          sdbSetRawStatus(pRebConsumer, SDB_STATUS_READY);
+          sdbSetRawStatus(pConsumerRaw, SDB_STATUS_READY);
           mndTransAppendRedolog(pTrans, pConsumerRaw);
         }
       }
@@ -377,9 +377,9 @@ static int32_t mndProcessDoRebalanceMsg(SMnodeMsg *pMsg) {
 
       // send msg to vnode
       // log rebalance statistics
-      SSdbRaw *pSubRaw = mndSubscribeActionEncode(pSub);
-      sdbSetRawStatus(pSubRaw, SDB_STATUS_READY);
-      mndTransAppendRedolog(pTrans, pSubRaw);
+      /*SSdbRaw *pSubRaw = mndSubscribeActionEncode(pSub);*/
+      /*sdbSetRawStatus(pSubRaw, SDB_STATUS_READY);*/
+      /*mndTransAppendRedolog(pTrans, pSubRaw);*/
     }
     mndReleaseSubscribe(pMnode, pSub);
   }