Chia-Ping Tsai created KAFKA-16774:
--------------------------------------
Summary: fix flaky
StreamThreadTest#shouldCloseAllTaskProducersOnCloseIfEosEnabled
Key: KAFKA-16774
URL: https://issues.apache.org/jira/browse/KAFKA-16774
Project: Kafka
Issue Type: Test
Reporter: Chia-Ping Tsai
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)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
