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

[A. Sophie Blee-Goldman (Jira)]

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)