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

Posted to dev@kafka.apache.org by "Damian Guy (JIRA)" <ji...@apache.org> on 2017/02/02 12:05:54 UTC

[jira] [Assigned] (KAFKA-4724) Clean up of state directories has a race condition and can possibly remove stores that are still used

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

Damian Guy reassigned KAFKA-4724:
---------------------------------

    Assignee: Damian Guy

> Clean up of state directories has a race condition and can possibly remove stores that are still used
> -----------------------------------------------------------------------------------------------------
>
>                 Key: KAFKA-4724
>                 URL: https://issues.apache.org/jira/browse/KAFKA-4724
>             Project: Kafka
>          Issue Type: Bug
>          Components: streams
>    Affects Versions: 0.10.2.0
>            Reporter: Damian Guy
>            Assignee: Damian Guy
>             Fix For: 0.10.3.0
>
>
> Currently, each {{StreamThread}} cleans up unused state directories based on the config {{StreamsConfig.STATE_CLEANUP_DELAY_MS_CONFIG}}. 
> In situations where there are multiple threads configured this can lead to a race condition where the state directory gets removed by one thread when the task has been assigned (but not yet taken a lock) to another thread in the process.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)