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