cadonna opened a new pull request, #14403: URL: https://github.com/apache/kafka/pull/14403
The state directory throws a lock exception during intitialisation if a task state directory is still locked by the stream thread that previously owned the task. When this happens Streams catches the lock exception, ignores the exception, and tries to initialize the task in the next exception. In the state updater code path we missed to catch the lock exception when Streams recycles a task. That leads to the lock exception thrown to the exception handler which is unexpected and leads to test failures. *More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of testing strategy (including rationale) for the feature or bug fix. Unit and/or integration tests are expected for any behaviour change and system tests should be considered for larger changes.* ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) -- 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. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
