Major Description
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.
Attachments
Issue Links
- links to
