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; } }