kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cmcc...@apache.org
Subject [kafka] branch trunk updated: MINOR: Remove errant lock.unlock() call from RoundTripWorker (#6612)
Date Sat, 20 Apr 2019 17:43:46 GMT
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.barrett@outlook.com>
AuthorDate: Sat Apr 20 13:43:35 2019 -0400

    MINOR: Remove errant lock.unlock() call from RoundTripWorker (#6612)
    
    Reviewers: Colin P. McCabe <cmccabe@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) {


Mime
View raw message