Hello @asutosh936, I do not know if you already did, maybe we can consider using the `try-with-resources` statement here, like:
```
try (FileChannel fileChannel = channels.remove(taskId)) {
lockAndOwner.lock.release();
log.debug("{} Released state dir lock for task {}", logPrefix(), taskId);
}
```
What do you think?
[ Full content available at: https://github.com/apache/kafka/pull/5574 ]
This message was relayed via gitbox.apache.org for [email protected]
