GitHub user wwj-radish added a comment to the discussion: 
controller通知broker变更失败,导致两个broker一直是master

这是controller通知broker变更角色失败的完整日志:
```
2023-06-08 11:31:17 INFO 
io.openmessaging.storage.dledger.statemachine.StateMachineCaller - Apply 1 
events index from 2 to 2 on controller group1#n2
2023-06-08 11:31:17 INFO ControllerManager_NotifyService_1 - Try notify broker 
192.168.105.105:10911 that role changed, 
RoleChangeNotifyEntry:org.apache.rocketmq.remoting.protocol.body.RoleChangeNotifyEntry@272b4d14
2023-06-08 11:31:17 INFO ControllerManager_NotifyService_1 - createChannel: 
begin to connect remote host[192.168.105.105:10911] asynchronously
2023-06-08 11:31:17 INFO NettyClientWorkerThread_1 - NETTY CLIENT PIPELINE: 
CONNECT  UNKNOWN => 192.168.105.105:10911
2023-06-08 11:31:17 WARN ControllerManager_NotifyService_1 - createChannel: 
connect remote host[192.168.105.105:10911] failed, 
AbstractBootstrap$PendingRegistrationPromise@20628da(failure: 
io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: 
/192.168.105.105:10911)
2023-06-08 11:31:17 ERROR ControllerManager_NotifyService_1 - Failed to notify 
broker 192.168.105.105:10911 that role changed
org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to  
failed
        at 
org.apache.rocketmq.remoting.netty.NettyRemotingClient.invokeOneway(NettyRemotingClient.java:759)
        at 
org.apache.rocketmq.controller.ControllerManager.doNotifyBrokerRoleChanged(ControllerManager.java:210)
        at 
org.apache.rocketmq.controller.ControllerManager$NotifyService.lambda$notifyBroker$0(ControllerManager.java:302)
        at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:750)
2023-06-08 11:31:17 INFO NettyClientWorkerThread_1 - NETTY CLIENT PIPELINE: 
CLOSE 
2023-06-08 11:31:17 INFO NettyClientWorkerThread_1 - closeChannel: the 
channel[192.168.105.105:10911] was removed from channel table
2023-06-08 11:31:17 INFO NettyClientWorkerThread_1 - NETTY CLIENT PIPELINE: 
CLOSE 
2023-06-08 11:31:17 INFO NettyClientWorkerThread_1 - eventCloseChannel: the 
channel[null] has been removed from the channel table before
``` 

GitHub link: 
https://github.com/apache/rocketmq/discussions/6869#discussioncomment-6117856

----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org

Reply via email to