This is an automated email from the ASF dual-hosted git repository.
zhoubo pushed a commit to branch 5.0.0-alpha
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/5.0.0-alpha by this push:
new ededeb6 [ISSUE #3371] Part A: Fix stack overflow exception when set
message mode #3372
ededeb6 is described below
commit ededeb67aff530ee45c2c872a9f77a485ba89f59
Author: 张旭 <[email protected]>
AuthorDate: Tue Sep 28 13:56:55 2021 +0800
[ISSUE #3371] Part A: Fix stack overflow exception when set message mode
#3372
Co-authored-by: zhangxu16 <[email protected]>
---
.../apache/rocketmq/broker/loadbalance/MessageRequestModeManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/loadbalance/MessageRequestModeManager.java
b/broker/src/main/java/org/apache/rocketmq/broker/loadbalance/MessageRequestModeManager.java
index 2b21d3a..b5472bc 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/loadbalance/MessageRequestModeManager.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/loadbalance/MessageRequestModeManager.java
@@ -26,7 +26,7 @@ import
org.apache.rocketmq.remoting.protocol.RemotingSerializable;
public class MessageRequestModeManager extends ConfigManager {
- private BrokerController brokerController;
+ private transient BrokerController brokerController;
private ConcurrentHashMap<String, ConcurrentHashMap<String,
SetMessageRequestModeRequestBody>>
messageRequestModeMap = new ConcurrentHashMap<String,
ConcurrentHashMap<String, SetMessageRequestModeRequestBody>>();