You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2023/01/31 07:25:00 UTC
[jira] [Assigned] (KAFKA-14650) IQv2 can throw ConcurrentModificationException when accessing Tasks
[ 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)