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)
