Ted Yu created KAFKA-7345:
-----------------------------
Summary: Potentially unclosed FileChannel in StateDirectory#unlock
Key: KAFKA-7345
URL: https://issues.apache.org/jira/browse/KAFKA-7345
Project: Kafka
Issue Type: Bug
Components: streams
Reporter: Ted Yu
{code}
lockAndOwner.lock.release();
log.debug("{} Released state dir lock for task {}", logPrefix(),
taskId);
final FileChannel fileChannel = channels.remove(taskId);
if (fileChannel != null) {
fileChannel.close();
{code}
If {{lockAndOwner.lock.release()}} throws IOE, the closing of the FileChannel
would be skipped.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
