diff --git a/source/dnode/mnode/impl/inc/mndSubscribe.h b/source/dnode/mnode/impl/inc/mndSubscribe.h
index b8e651e386..2d99c67858 100644
--- a/source/dnode/mnode/impl/inc/mndSubscribe.h
+++ b/source/dnode/mnode/impl/inc/mndSubscribe.h
@@ -28,9 +28,6 @@ void    mndCleanupSubscribe(SMnode *pMnode);
 SMqSubscribeObj *mndAcquireSubscribe(SMnode *pMnode, char *CGroup, char *topicName);
 void             mndReleaseSubscribe(SMnode *pMnode, SMqSubscribeObj *pSub);
 
-SSdbRaw *mndSubscribeActionEncode(SMqSubscribeObj *pSub);
-SSdbRow *mndSubscribeActionDecode(SSdbRaw *pRaw);
-
 #ifdef __cplusplus
 }
 #endif
diff --git a/source/dnode/mnode/impl/src/mndSubscribe.c b/source/dnode/mnode/impl/src/mndSubscribe.c
index eca59260cc..cc34e30d90 100644
--- a/source/dnode/mnode/impl/src/mndSubscribe.c
+++ b/source/dnode/mnode/impl/src/mndSubscribe.c
@@ -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 = mndSubActionEncode(pSub);
+      sdbSetRawStatus(pSubRaw, SDB_STATUS_READY);
+      mndTransAppendRedolog(pTrans, pSubRaw);
     }
     mndReleaseSubscribe(pMnode, pSub);
   }