You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2025/12/15 14:42:00 UTC

[jira] [Updated] (KAFKA-19994) TaskManager may not close all tasks on task timeouts

     [ https://issues.apache.org/jira/browse/KAFKA-19994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Lucas Brutschy updated KAFKA-19994:
-----------------------------------
    Fix Version/s: 4.2.0

> 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
>            Priority: Blocker
>             Fix For: 4.2.0
>
>
> 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)