diff --git a/controller/src/main/java/org/apache/rocketmq/controller/impl/DLedgerController.java b/controller/src/main/java/org/apache/rocketmq/controller/impl/DLedgerController.java index ba8a156fb1..bb963e3332 100644 --- a/controller/src/main/java/org/apache/rocketmq/controller/impl/DLedgerController.java +++ b/controller/src/main/java/org/apache/rocketmq/controller/impl/DLedgerController.java @@ -112,7 +112,7 @@ public class DLedgerController implements Controller { // Register statemachine and role handler. this.dLedgerServer = new DLedgerServer(dLedgerConfig, nettyServerConfig, nettyClientConfig, channelEventListener); this.dLedgerServer.registerStateMachine(this.statemachine); - this.dLedgerServer.getdLedgerLeaderElector().addRoleChangeHandler(this.roleHandler); + this.dLedgerServer.getDLedgerLeaderElector().addRoleChangeHandler(this.roleHandler); } @Override