Merge pull request #10187 from taosdata/feature/tq

fix subscribe encode

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

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);
   }