[ https://issues.apache.org/jira/browse/KAFKA-14650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Matthias J. Sax reassigned KAFKA-14650: --------------------------------------- Assignee: Guozhang Wang > IQv2 can throw ConcurrentModificationException when accessing Tasks > -------------------------------------------------------------------- > > Key: KAFKA-14650 > URL: https://issues.apache.org/jira/browse/KAFKA-14650 > Project: Kafka > Issue Type: Bug > Components: streams > Affects Versions: 3.4.0 > Reporter: A. Sophie Blee-Goldman > Assignee: Guozhang Wang > Priority: Major > > From failure in *[PositionRestartIntegrationTest.verifyStore[cache=false, > log=true, supplier=IN_MEMORY_WINDOW, > kind=PAPI]|https://ci-builds.apache.org/job/Kafka/job/kafka/job/3.4/63/testReport/junit/org.apache.kafka.streams.integration/PositionRestartIntegrationTest/Build___JDK_11_and_Scala_2_13___verifyStore_cache_false__log_true__supplier_IN_MEMORY_WINDOW__kind_PAPI_/]* > java.util.ConcurrentModificationException > at > java.base/java.util.TreeMap$PrivateEntryIterator.nextEntry(TreeMap.java:1208) > at java.base/java.util.TreeMap$EntryIterator.next(TreeMap.java:1244) > at java.base/java.util.TreeMap$EntryIterator.next(TreeMap.java:1239) > at java.base/java.util.HashMap.putMapEntries(HashMap.java:508) > at java.base/java.util.HashMap.putAll(HashMap.java:781) > at > org.apache.kafka.streams.processor.internals.Tasks.allTasksPerId(Tasks.java:361) > at > org.apache.kafka.streams.processor.internals.TaskManager.allTasks(TaskManager.java:1537) > at > org.apache.kafka.streams.processor.internals.StreamThread.allTasks(StreamThread.java:1278) > at org.apache.kafka.streams.KafkaStreams.query(KafkaStreams.java:1921) > at > org.apache.kafka.streams.integration.utils.IntegrationTestUtils.iqv2WaitForResult(IntegrationTestUtils.java:168) > at > org.apache.kafka.streams.integration.PositionRestartIntegrationTest.shouldReachExpectedPosition(PositionRestartIntegrationTest.java:438) > at > org.apache.kafka.streams.integration.PositionRestartIntegrationTest.verifyStore(PositionRestartIntegrationTest.java:423) -- This message was sent by Atlassian Jira (v8.20.10#820010)