This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a commit to branch 4.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/4.0 by this push:
new 62af101b1ad MINOR: improve logging for Kafka Streams stateful task
management (#20942)
62af101b1ad is described below
commit 62af101b1ad242b19a05e1545d4873ca11be3636
Author: Matthias J. Sax <[email protected]>
AuthorDate: Fri Nov 21 05:42:11 2025 -0800
MINOR: improve logging for Kafka Streams stateful task management (#20942)
Changing log level from ERROR to WARN, as it's expected that this can
happen, and we should not incorrectly make users worry about it.
Reviewers: PoAn Yang <[email protected]>, Colt McNealy
<[email protected]>, Lucas Brutschy <[email protected]>,
Chia-Ping Tsai <[email protected]>
---
.../org/apache/kafka/streams/processor/internals/StateManagerUtil.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManagerUtil.java
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManagerUtil.java
index 4fff7b600fc..aeb7406a1be 100644
---
a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManagerUtil.java
+++
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManagerUtil.java
@@ -147,7 +147,7 @@ final class StateManagerUtil {
}
}
} else {
- log.error("Failed to acquire lock while closing the state
store for {} task {}", taskType, id);
+ log.warn("Unable to acquire lock while closing the state store
for {} task {}", taskType, id);
}
} catch (final IOException e) {
final ProcessorStateException exception = new
ProcessorStateException(
