This is an automated email from the ASF dual-hosted git repository.
ableegoldman pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from d22c492 MINOR: Fix newly added client side timeout tests in
`KafkaAdminClientTest` (#10398)
add 0189298 KAFKA-12288: remove task-level filesystem locks (#10342)
No new revisions were added by this update.
Summary of changes:
.../processor/internals/ProcessorStateManager.java | 2 +-
.../processor/internals/StateDirectory.java | 121 ++++++---------------
.../processor/internals/StateManagerUtil.java | 11 +-
.../streams/processor/internals/TaskManager.java | 23 +---
.../integration/RestoreIntegrationTest.java | 8 +-
.../integration/StandbyTaskEOSIntegrationTest.java | 4 +-
.../processor/internals/ActiveTaskCreatorTest.java | 4 +-
.../internals/ProcessorStateManagerTest.java | 4 +-
.../processor/internals/StateDirectoryTest.java | 105 ++++++------------
.../processor/internals/StateManagerUtilTest.java | 70 ++----------
.../processor/internals/StreamTaskTest.java | 2 +-
.../processor/internals/StreamThreadTest.java | 2 +-
12 files changed, 96 insertions(+), 260 deletions(-)
