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)