diff --git a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
index 32655ce4050bf653c7b33e9f550fd41c1aedf831..3418e82094717ed99f227add5640569793633e57 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
@@ -806,9 +806,7 @@ public class BrokerController {
             this.filterServerManager.start();
         }
 
-        if (messageStoreConfig.isEnableDLegerCommitLog()) {
-            changeToSlave(((DLedgerCommitLog)((DefaultMessageStore) messageStore).getCommitLog()).getId());
-        } else {
+        if (!messageStoreConfig.isEnableDLegerCommitLog()) {
             startProcessorByHa(messageStoreConfig.getBrokerRole());
             handleSlaveSynchronize(messageStoreConfig.getBrokerRole());
         }