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 df436cc944d MINOR: improve logging for Kafka Streams stateful task
management (#20942)
df436cc944d is described below
commit df436cc944d954f4fd8eec7afc36a330e6652ce6
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 ca92710e207..6990bd29029 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(
