If ClosedChannelException is thrown out of lock.release(), unlock() would repeatedly try to release the lock (since locks.remove(taskId) call is moved last).
[ Full content available at: https://github.com/apache/kafka/pull/5574 ] This message was relayed via gitbox.apache.org for [email protected]
