[ https://issues.apache.org/jira/browse/KAFKA-4724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Damian Guy updated KAFKA-4724: ------------------------------ Summary: Clean up of state directories can possibly remove stores that are about to be used by another thread (was: Clean up of state directories has a race condition and can possibly remove stores that are still used) > Clean up of state directories can possibly remove stores that are about to be > used by another thread > ---------------------------------------------------------------------------------------------------- > > 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)