Lucas Brutschy created KAFKA-19994:
--------------------------------------
Summary: TaskManager may not close all tasks on task timeouts
Key: KAFKA-19994
URL: https://issues.apache.org/jira/browse/KAFKA-19994
Project: Kafka
Issue Type: Bug
Components: streams
Reporter: Lucas Brutschy
Assignee: Lucas Brutschy
When a {{TimeoutException}} occurs while trying to put multiple active tasks
back into running, we will add the timed out task back to the state updater, so
that it gets properly closed during unclean shutdown of the thread.
However, if we run into a Task timeout (failing to make progress for a long
time), we will rethrow a StreamsException wrapping the TimeoutException we have
drained multiple tasks from the state updater, they will be lost, and not added
back to the state updater, and therefore not be closed correctly. The task
directories remain locked, causing issues trying to replace the stream thread.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
