This is an automated email from the ASF dual-hosted git repository.
lucasbru pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from b4e1deb43a7 MINOR: Few cleanups
add d04f5348925 KAFKA-17109: implement exponential backoff for state
directory lock (#17116)
No new revisions were added by this update.
Summary of changes:
.../processor/internals/StateDirectory.java | 37 ++++++++++++++++++++++
.../processor/internals/StateManagerUtil.java | 25 ++++++++-------
.../processor/internals/StandbyTaskTest.java | 2 ++
.../processor/internals/StateDirectoryTest.java | 16 ++++++++++
.../processor/internals/StateManagerUtilTest.java | 16 ++++++++++
.../processor/internals/StreamTaskTest.java | 2 ++
6 files changed, 87 insertions(+), 11 deletions(-)
