MINOR: remove old comment in streams StateDirectory (apache#18546)

Reviewers: Bruno Cadonna <cadonna@apache.org>, Chia-Ping Tsai <chia7712@gmail.com>
TaiJuWu · Jan 15, 2025 · 512e0c9 · 512e0c9
1 parent e12db66
commit 512e0c9
Showing 1 changed file with 0 additions and 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
@@ -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;
         }
     }