You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2021/07/21 13:26:43 UTC

[GitHub] [rocketmq] susonglin opened a new issue #3169: [TIMEOUT_CLEAN_QUEUE]broker busy

susonglin opened a new issue #3169:
URL: https://github.com/apache/rocketmq/issues/3169


   error: org.apache.rocketmq.client.exception.MQBrokerException: CODE: 2  DESC: [TIMEOUT_CLEAN_QUEUE]broker busy, start flow control for a while, period in queue: 1001ms, size of queue: 265
   
   version: 4.5.0. Multi Master Multi Slave mode
   
   os: centos7
   
   brokerRole=SYNC_MASTER
   flushDiskType=ASYNC_FLUSH
   useReentrantLockWhenPutMessage=true
   sendMessageThreadPoolNums=32
   waitTimeMillsInSendQueue=1000
   transientStorePoolEnable=true
   transferMsgByHeap=false
   warmMapedFileEnable=false
   
   We want to upgrade rocketmq disk without stopping, And adjust the brush strategy. from SYNC_FLUSH to ASYNC_FLUSH.
   
   We shut down the write traffic of the old cluster through wipewriteperm.
   
   There is no exception before upgrade, but after upgrade, this exception is thrown frequently.
   
   I'm confused
   
   
   


-- 
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: dev-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq] odbozhou closed issue #3169: [TIMEOUT_CLEAN_QUEUE]broker busy

Posted by GitBox <gi...@apache.org>.

odbozhou closed issue #3169:
URL: https://github.com/apache/rocketmq/issues/3169


   


-- 
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: dev-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq] francisoliverlee commented on issue #3169: [TIMEOUT_CLEAN_QUEUE]broker busy

Posted by GitBox <gi...@apache.org>.

francisoliverlee commented on issue #3169:
URL: https://github.com/apache/rocketmq/issues/3169#issuecomment-884328051


   check some ref bellow:
   https://github.com/apache/rocketmq/issues/2132
   https://github.com/apache/rocketmq/issues/2471
   https://www.jianshu.com/p/dd0469a326b6


-- 
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: dev-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq] susonglin commented on issue #3169: [TIMEOUT_CLEAN_QUEUE]broker busy

Posted by GitBox <gi...@apache.org>.

susonglin commented on issue #3169:
URL: https://github.com/apache/rocketmq/issues/3169#issuecomment-885425220


   > 检查一些参考波纹管：
   > [#2132 ](https://github.com/apache/rocketmq/issues/2132)
   > [#2471 ](https://github.com/apache/rocketmq/issues/2471)
   > https://www.jianshu.com/p/dd0469a326b6
   
   thanks，I changed to these configurations, and there was no exception. I'll follow up the reason
   
   brokerRole=SYNC_MASTER
   flushDiskType=SYNC_FLUSH
   useReentrantLockWhenPutMessage=true
   sendMessageThreadPoolNums=32
   waitTimeMillsInSendQueue=500


-- 
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: dev-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org