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 [email protected].
To unsubscribe, please send an email to: [email protected]
