You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by cm...@apache.org on 2019/04/20 17:43:46 UTC
[kafka] branch trunk updated: MINOR: Remove errant lock.unlock()
call from RoundTripWorker (#6612)
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 <bo...@outlook.com>
AuthorDate: Sat Apr 20 13:43:35 2019 -0400
MINOR: Remove errant lock.unlock() call from RoundTripWorker (#6612)
Reviewers: Colin P. McCabe <cm...@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) {