You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Dongjin Lee (Jira)" <ji...@apache.org> on 2021/06/10 09:37:00 UTC

[jira] [Created] (KAFKA-12928) Add a check whether the Task's statestore is actually a directory

Dongjin Lee created KAFKA-12928:
-----------------------------------

             Summary: Add a check whether the Task's statestore is actually a directory
                 Key: KAFKA-12928
                 URL: https://issues.apache.org/jira/browse/KAFKA-12928
             Project: Kafka
          Issue Type: Bug
          Components: streams
            Reporter: Dongjin Lee
            Assignee: Dongjin Lee


I found this problem while working on [KAFKA-10585|https://issues.apache.org/jira/browse/KAFKA-10585].

As of present, StateDirectory checks whether the Task's statestore directory exists and, if not, creates it. Since it does not check whether it is actually a directory, for example, if a regular file occupies the Task's statestore's path, the validation logic may be detoured.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)