[
https://issues.apache.org/jira/browse/KAFKA-7709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16710529#comment-16710529
]
ASF GitHub Bot commented on KAFKA-7709:
---------------------------------------
markcho opened a new pull request #6005: KAFKA-7709: Fix
ConcurrentModificationException when retrieving expired inflight batches on
multiple partitions.
URL: https://github.com/apache/kafka/pull/6005
*Summary of testing strategy (including rationale)
for the feature or bug fix. Unit and/or integration
tests are expected for any behaviour change and
system tests should be considered for larger changes.*
- Unit test
- Integration test
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> ConcurrentModificationException occurs when iterating through multiple
> partitions in Sender.getExpiredInflightBatches
> ---------------------------------------------------------------------------------------------------------------------
>
> Key: KAFKA-7709
> URL: https://issues.apache.org/jira/browse/KAFKA-7709
> Project: Kafka
> Issue Type: Bug
> Components: core
> Affects Versions: 2.1.0
> Reporter: Mark Cho
> Priority: Major
>
> In Sender.getExpiredInflightBatches method, delivery.timeout on multiple
> partitions causes ConcurrentModificationException due to the underlying Java
> collection being mutated while being iterated on.
> In Java HashMap, you cannot mutate the underlying map while iterating through
> it, as this will cause ConcurrentModificationException.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
