From b59a82225e0be6bf63625569443abf2966df95d7 Mon Sep 17 00:00:00 2001
From: Liu Jicong <liujicong@qq.com>
Date: Thu, 10 Feb 2022 11:29:51 +0800
Subject: [PATCH] fix compile

---
 source/dnode/mnode/impl/src/mndSubscribe.c | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/source/dnode/mnode/impl/src/mndSubscribe.c b/source/dnode/mnode/impl/src/mndSubscribe.c
index 4824f2d06b..eca59260cc 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);
   }
-- 
GitLab