From 512e0c962841b33e525519560fd30896e7b0a55b Mon Sep 17 00:00:00 2001
From: Alieh Saeedi <107070585+aliehsaeedii@users.noreply.github.com>
Date: Wed, 15 Jan 2025 18:07:55 +0100
Subject: [PATCH] MINOR: remove old comment in streams StateDirectory (#18546)

Reviewers: Bruno Cadonna <cadonna@apache.org>, Chia-Ping Tsai <chia7712@gmail.com>
---
 .../apache/kafka/streams/processor/internals/StateDirectory.java | 1 -
 1 file changed, 1 deletion(-)

diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
index 04a62bad1bfef..97525b8972d82 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
@@ -482,7 +482,6 @@ synchronized boolean lock(final TaskId taskId) {
             throw new IllegalStateException("The state directory has been deleted");
         } else {
             lockedTasksToOwner.put(taskId, Thread.currentThread());
-            // make sure the task directory actually exists, and create it if not
             return true;
         }
     }