[KAFKA-16774] fix flaky StreamThreadTest#shouldCloseAllTaskProducersOnCloseIfEosEnabled

• Type: Test
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 3.8.0
• Component/s: streams, unit tests
• Labels: flaky-test
• Assignee: Bruno Cadonna
• Reporter: Chia-Ping Tsai
• Created: 15/May/24 18:20
• Updated: 17/May/24 16:20
• Resolved: 17/May/24 06:36

Description

java.util.ConcurrentModificationException
at java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1720)
at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
at java.base/java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:921)
at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at java.base/java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:682)
at org.apache.kafka.streams.processor.internals.TaskManager.allTasks(TaskManager.java:1686)
at org.apache.kafka.streams.processor.internals.TaskManager.releaseLockedUnassignedTaskDirectories(TaskManager.java:1364)
at org.apache.kafka.streams.processor.internals.TaskManager.handleRebalanceComplete(TaskManager.java:208)
at org.apache.kafka.streams.processor.internals.StreamsRebalanceListener.onPartitionsAssigned(StreamsRebalanceListener.java:79)
at org.apache.kafka.streams.processor.internals.StreamThreadTest.shouldCloseAllTaskProducersOnCloseIfEosEnabled(StreamThreadTest.java:1408)
at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)

Issue Links

• links to: GitHub Pull Request #15978