This is an automated email from the ASF dual-hosted git repository.
cmccabe pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 964e90a MINOR: Remove errant lock.unlock() call from RoundTripWorker
(#6612)
964e90a is described below
commit 964e90a725f7a0bcaf03735f81e525388868b4d9
Author: Bob Barrett <bob.barr...@outlook.com>
AuthorDate: Sat Apr 20 13:43:35 2019 -0400
MINOR: Remove errant lock.unlock() call from RoundTripWorker (#6612)
Reviewers: Colin P. McCabe <cmcc...@apache.org>
---
.../main/java/org/apache/kafka/trogdor/workload/RoundTripWorker.java | 2 --
1 file changed, 2 deletions(-)
diff --git
a/tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorker.java
b/tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorker.java
index d08d807..7eab2de 100644
--- a/tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorker.java
+++ b/tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorker.java
@@ -385,8 +385,6 @@ public class RoundTripWorker implements TaskWorker {
log.debug("{}: Consumer got WakeupException", id, e);
} catch (TimeoutException e) {
log.debug("{}: Consumer got TimeoutException", id, e);
- } finally {
- lock.unlock();
}
}
} catch (Throwable e) {
