Lucas Brutschy created KAFKA-16097: -------------------------------------- Summary: State updater removes task without pending action in EOSv2 Key: KAFKA-16097 URL: https://issues.apache.org/jira/browse/KAFKA-16097 Project: Kafka Issue Type: Bug Components: streams Reporter: Lucas Brutschy
A long-running soak encountered the following exception: {code:java} [2024-01-08 03:06:00,586] ERROR [i-081c089d2ed054443-StreamThread-3] Thread encountered an error processing soak test (org.apache.kafka.streams.StreamsSoakTest) java.lang.IllegalStateException: Got a removed task 1_0 from the state updater that is not for recycle, closing, or updating input partitions; this should not happen at org.apache.kafka.streams.processor.internals.TaskManager.handleRemovedTasksFromStateUpdater(TaskManager.java:939) at org.apache.kafka.streams.processor.internals.TaskManager.checkStateUpdater(TaskManager.java:788) at org.apache.kafka.streams.processor.internals.StreamThread.checkStateUpdater(StreamThread.java:1141) at org.apache.kafka.streams.processor.internals.StreamThread.runOnceWithoutProcessingThreads(StreamThread.java:949) at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:686) at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:645) [2024-01-08 03:06:00,587] ERROR [i-081c089d2ed054443-StreamThread-3] stream-client [i-081c089d2ed054443] Encountered the following exception during processing and sent shutdown request for the entire application. (org.apache.kafka.streams.KafkaStreams) org.apache.kafka.streams.errors.StreamsException: java.lang.IllegalStateException: Got a removed task 1_0 from the state updater that is not for recycle, closing, or updating input partitions; this should not happen at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:729) at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:645) Caused by: java.lang.IllegalStateException: Got a removed task 1_0 from the state updater that is not for recycle, closing, or updating input partitions; this should not happen at org.apache.kafka.streams.processor.internals.TaskManager.handleRemovedTasksFromStateUpdater(TaskManager.java:939) at org.apache.kafka.streams.processor.internals.TaskManager.checkStateUpdater(TaskManager.java:788) at org.apache.kafka.streams.processor.internals.StreamThread.checkStateUpdater(StreamThread.java:1141) at org.apache.kafka.streams.processor.internals.StreamThread.runOnceWithoutProcessingThreads(StreamThread.java:949) at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:686) ... 1 more{code} -- This message was sent by Atlassian Jira (v8.20.10#820010)