Skip to content

Commit 964e90a

Browse files
bob-barrettcmccabe
authored andcommitted
MINOR: Remove errant lock.unlock() call from RoundTripWorker (apache#6612)
Reviewers: Colin P. McCabe <[email protected]>
1 parent 6538e9e commit 964e90a

File tree

1 file changed

+0
-2
lines changed

1 file changed

+0
-2
lines changed

tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorker.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -385,8 +385,6 @@ public void run() {
385385
log.debug("{}: Consumer got WakeupException", id, e);
386386
} catch (TimeoutException e) {
387387
log.debug("{}: Consumer got TimeoutException", id, e);
388-
} finally {
389-
lock.unlock();
390388
}
391389
}
392390
} catch (Throwable e) {

0 commit comments

Comments
 (0)