[
https://issues.apache.org/jira/browse/KAFKA-13787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516068#comment-17516068
]
Matthias J. Sax edited comment on KAFKA-13787 at 4/15/22 8:56 PM:
------------------------------------------------------------------
`StateDirectory` should have all relevant code. Not sure why it does not delete
the `kafka-streams-process-metadata` file – for the `.lock` file it's ok, as we
hold the lock all the time and it will be deleted when the directory is deleted.
[~vvcephei] might know more about the file in question?
was (Author: mjsax):
`StateDirectory` should have all relevant code. Not sure why it does not delete
the `kafka-streams-process-metadata` file – for the `.lock` file it's ok, as we
hold the lock all the time and it will be deleted when the directory is deleted.
[~vvcephei] might now more about the file in question?
> Failed to delete state store directory for it is not empty
> ----------------------------------------------------------
>
> Key: KAFKA-13787
> URL: https://issues.apache.org/jira/browse/KAFKA-13787
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 3.0.0
> Reporter: Nico Pommerening
> Priority: Major
> Attachments: bug-log.txt
>
>
> On Kafka Streams shutdown the Cleanup of state directories seems not to work,
> since the lock and metadata file seem not to be deleted.
> Relevant WARN logging:
> 2022-03-31 10:34:41,689 WARN [SpringApplicationShutdownHook]
> org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread
> [SpringApplicationShutdownHook] Failed to delete state store directory of
> /kafka-streams-statestore/555b9965-95e3-4c92-b467-1d283428da5d/test-test-run-kpi
> for it is not empty
>
> Left over files in directory:
> * .lock
> * kafka-streams-process-metadata
>
> I'm not sure what the consequences of a unclean state cleanup are, but I
> would like to get rid of the Warning.
> I attached a bigger log extract and I've already patched the StateDirectory
> implementation which I'll try to contribute.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
