[jira] [Created] (KAFKA-19696) Re-enable SmokeTestDriverIntegrationTest for processing threads

["Lucas Brutschy (Jira)" <ji...@apache.org>]

Lucas Brutschy created KAFKA-19696:
--------------------------------------

             Summary: Re-enable SmokeTestDriverIntegrationTest for processing threads
                 Key: KAFKA-19696
                 URL: https://issues.apache.org/jira/browse/KAFKA-19696
             Project: Kafka
          Issue Type: Task
          Components: streams
            Reporter: Lucas Brutschy


The test fails occasionally with a race condition like this:

 

 
{code:java}
 2_0 RUNNING StreamTask(active): org.apache.kafka.streams.errors.StreamsException: java.util.ConcurrentModificationExceptionorg.apache.kafka.streams.errors.StreamsException: java.util.ConcurrentModificationException at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:977) at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:894)Caused by: java.util.ConcurrentModificationException at java.base/java.util.HashMap$HashIterator.nextNode(HashMap.java:1597) at java.base/java.util.HashMap$KeyIterator.next(HashMap.java:1620) at org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer.resume(ClassicKafkaConsumer.java:979) at org.apache.kafka.clients.consumer.KafkaConsumer.resume(KafkaConsumer.java:1509) at org.apache.kafka.streams.processor.internals.StreamTask.resumePollingForPartitionsWithAvailableSpace(StreamTask.java:623) at org.apache.kafka.streams.processor.internals.TaskManager.resumePollingForPartitionsWithAvailableSpace(TaskManager.java:1866) at org.apache.kafka.streams.processor.internals.StreamThread.runOnceWithProcessingThreads(StreamThread.java:1355) at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:932) {code}
 

Since the feature is not actively developed by anybody, we disable this test. This ticket is to re-enable the test when the race condition is fixed.

 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)