ableegoldman opened a new pull request #10342: URL: https://github.com/apache/kafka/pull/10342
The filesystem locks don't protect access between StreamThreads, only across different instances of the same Streams application. Running multiple processes in the same physical state directory is not supported, and as of [PR #9978](https://github.com/apache/kafka/pull/9978) it's explicitly guarded against), so there's no reason to continue locking the task directories with anything heavier than an in-memory map. Ripping out out the task-level filesystem locks not only cleans up the code, but removes an occasional source of trouble due to IOExceptions. We now use only an umbrella lock of the state directory itself which is held for the lifetime of the application ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
