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/11/18 09:42:34 UTC

[GitHub] [rocketmq] drpmma opened a new issue, #5542: Fix ConsumerProcessor lockBatchMQ future allOf data race issue

drpmma opened a new issue, #5542:
URL: https://github.com/apache/rocketmq/issues/5542

   
   1. Please describe the issue you observed:
   
   There is a data race issue in ConsumerProcessor#lockBatchMQ.  
   
   https://github.com/apache/rocketmq/blob/0b24e875b7a8d424da0a618c892d6de79eb74343/proxy/src/main/java/org/apache/rocketmq/proxy/processor/ConsumerProcessor.java#L317-L337
   
   The result of `future0.thenAccept` should be added to `futureList` instead of future0.
   
   


-- 
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] drpmma closed issue #5542: ConsumerProcessor lockBatchMQ future allOf data race issue

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

drpmma closed issue #5542: ConsumerProcessor lockBatchMQ future allOf data race issue
URL: https://github.com/apache/rocketmq/issues/5542


-- 
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