[jira] [Created] (KAFKA-14650) IQv2 can throw ConcurrentModificationException when accessing Tasks

["A. Sophie Blee-Goldman (Jira)" <ji...@apache.org>]

A. Sophie Blee-Goldman created KAFKA-14650:
----------------------------------------------

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


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)