This is an automated email from the ASF dual-hosted git repository.

chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 512e0c96284 MINOR: remove old comment in streams StateDirectory 
(#18546)
512e0c96284 is described below

commit 512e0c962841b33e525519560fd30896e7b0a55b
Author: Alieh Saeedi <107070585+aliehsaee...@users.noreply.github.com>
AuthorDate: Wed Jan 15 18:07:55 2025 +0100

    MINOR: remove old comment in streams StateDirectory (#18546)
    
    Reviewers: Bruno Cadonna <cado...@apache.org>, Chia-Ping Tsai 
<chia7...@gmail.com>
---
 .../org/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 04a62bad1bf..97525b8972d 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 @@ public class StateDirectory implements AutoCloseable {
             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;
         }
     }

Reply via email to