[
https://issues.apache.org/jira/browse/KAFKA-12667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321201#comment-17321201
]
A. Sophie Blee-Goldman commented on KAFKA-12667:
------------------------------------------------
Thanks [~antrenta]. As Bruno mentioned, we did discover this bug and fixed it
in trunk, but unfortunately missed the 2.6.2, 2.7.1, and 2.8.0 releases which
have all been in the release process.
I'm happy to backport the fix to the 2.8 branch once 2.8.0 is finally out the
door, and maybe to the 2.7 branch as well. It seems unlikely that there will be
a 2.6.3 release however.
Sorry for the trouble, I know it's a concerning message to see.
> Incorrect error log on StateDirectory close
> -------------------------------------------
>
> Key: KAFKA-12667
> URL: https://issues.apache.org/jira/browse/KAFKA-12667
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 2.7.0, 2.6.1
> Reporter: Jan Justesen
> Priority: Major
> Fix For: 2.6.3, 2.7.2
>
>
> {{In StateDirectory.close() an error is logged about unclean shutdown if all
> locks are in fact released, and nothing is logged in case of an unclean
> shutdown.}}
>
> {code:java}
> // all threads should be stopped and cleaned up by now, so none should remain
> holding a lock
> if (locks.isEmpty()) {
> log.error("Some task directories still locked while closing state, this
> indicates unclean shutdown: {}", locks);
> }
> {code}
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
