Nico Pommerening created KAFKA-13787:
----------------------------------------

             Summary: 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
         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)

Reply via email to