You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by GitBox <gi...@apache.org> on 2022/12/16 08:31:15 UTC
[GitHub] [rocketmq] riki-wang opened a new issue, #5714: Broker在DledgerController模式下开启transientStorePool引起system busy异常
riki-wang opened a new issue, #5714:
URL: https://github.com/apache/rocketmq/issues/5714
1. Problem
Broker在开启自动故障转移模式下，同时设置transientStorePoolEnable=true与brokerRole=SLAVE的情况下会引起客户端产生"system busy"异常
<img width="1482" alt="image" src="https://user-images.githubusercontent.com/23468936/208053095-799d65d3-04c1-466a-a766-6011ca4ada43.png">
2. Environment
- Centos 7.9
- CPU: 4 core
- Memory: 16GB
- RocketMQ Version: 5.0
- Broker config
- broker-c-1.conf
```
brokerClusterName=DC
brokerName=broker-c
brokerId=-1
deleteWhen=04
fileReservedTime=48
**brokerRole=SLAVE**
flushDiskType=ASYNC_FLUSH
enableControllerMode = true
controllerAddr = 127.0.0.1:59878
#allAckInSyncStateSet = true
namesrvAddr=127.0.0.1:9876
listenPort=58922
storePathRootDir=/data/rocketmq/master/store
storePathIndex=/data/rocketmq/master/store/index
storeCheckpoint=/data/rocketmq/master/store/checkpoint
abortFile=/data/rocketmq/master/store/abort
storePathCommitLog=/data/rocketmq/master/store/commitlog
storePathConsumerQueue=/data/rocketmq/master/store/consumequeue
storePathEpochFile=/data/rocketmq/master/store/storePathEpochFile
**transientStorePoolEnable=true**
transientStorePoolSize=2`
```
- broker-c-2.conf
```
brokerClusterName=DC
brokerName=broker-c
brokerId=-1
deleteWhen=04
fileReservedTime=48
**brokerRole=SLAVE**
flushDiskType=ASYNC_FLUSH
enableControllerMode = true
controllerAddr = 127.0.0.1:59878
allAckInSyncStateSet = true
namesrvAddr=127.0.0.1:9876
listenPort=59922
storePathRootDir=/data/rocketmq/slave/store
storePathIndex=/data/rocketmq/slave/store/index
storeCheckpoint=/data/rocketmq/slave/store/checkpoint
abortFile=/data/rocketmq/slave/store/abort
storePathCommitLog=/data/rocketmq/slave/store/commitlog
storePathConsumerQueue=/data/rocketmq/slave/store/consumequeue
storePathEpochFile=/data/rocketmq/slave/store/storePathEpochFile
**transientStorePoolEnable=true**
transientStorePoolSize=2
```
- contoller.conf
```
controllerDLegerGroup = group2
controllerDLegerPeers = n0-10.110.150.69:59878
controllerDLegerSelfId = n0
controllerStorePath=/data/rocketmq/controller
```
3. Steps to reproduce
- start namesrv
`nohup bin/mqnamesrv &`
- start controller
`nohup bin/mqcontroller -c conf/controller.conf`
- start broker
- `nohup bin/mqbroker -c conf/broker-c-1.conf &`
- `nohup bin/mqbroker -c conf/broker-c-2.conf &`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] RongtongJin commented on issue #5714: System busy exception when transientStorePoolEnable=true in controller mode
Posted by GitBox <gi...@apache.org>.
RongtongJin commented on issue #5714:
URL: https://github.com/apache/rocketmq/issues/5714#issuecomment-1354408118
Hi @riki-wang 我在controller模式下打开transientStorePoolEnable，正常情况下收发并未出现System busy，切换时也能及时恢复。想确认一下，当出现System busy exception，使用clusterList查看是否选出了Master？
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] riki-wang commented on issue #5714: System busy exception when transientStorePoolEnable=true in controller mode
Posted by GitBox <gi...@apache.org>.
riki-wang commented on issue #5714:
URL: https://github.com/apache/rocketmq/issues/5714#issuecomment-1354414543
> Hi @riki-wang 我在controller模式下打开transientStorePoolEnable，正常情况下收发并未出现System busy，切换时也能及时恢复。想确认一下，当出现System busy exception，使用clusterList查看是否选出了Master？
当transientStorePoolEnable=true与brokerRole=SLAVE同时设置时，slave节点似乎一直无法跟选举出的master通信
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] odbozhou closed issue #5714: System busy exception when transientStorePoolEnable=true in controller mode
Posted by GitBox <gi...@apache.org>.
odbozhou closed issue #5714: System busy exception when transientStorePoolEnable=true in controller mode
URL: https://github.com/apache/rocketmq/issues/5714
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] riki-wang commented on issue #5714: System busy exception when transientStorePoolEnable=true in controller mode
Posted by GitBox <gi...@apache.org>.
riki-wang commented on issue #5714:
URL: https://github.com/apache/rocketmq/issues/5714#issuecomment-1354410073
> Hi @riki-wang 我在controller模式下打开transientStorePoolEnable，正常情况下收发并未出现System busy，切换时也能及时恢复。想确认一下，当出现System busy exception，使用clusterList查看是否选出了Master？
还需要将brokerRole设置成SLAVE才会出现这个异常
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] RongtongJin commented on issue #5714: System busy exception when transientStorePoolEnable=true in controller mode
Posted by GitBox <gi...@apache.org>.
RongtongJin commented on issue #5714:
URL: https://github.com/apache/rocketmq/issues/5714#issuecomment-1354423299
> SLAVE
Good catch! I have reproduced it, I will find out the reason.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org