MINOR: improve logging for Kafka Streams stateful task management (#20942)

mjsax · web-flow · commit df436cc944d9 · 2025-11-21T21:42:11.000+08:00
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 &lt;payang@apache.org&gt;, Colt McNealy
 &lt;colt@littlehorse.io&gt;, Lucas Brutschy &lt;lbrutschy@confluent.io&gt;,
 Chia-Ping Tsai &lt;chia7712@gmail.com&gt;
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
@@ -147,7 +147,7 @@ static void closeStateManager(final Logger log,
                     }
                 }
             } 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(

Original file line number	Diff line number	Diff line change
`@@ -147,7 +147,7 @@ static void closeStateManager(final Logger log,`
`147`	`147`	`}`
`148`	`148`	`}`
`149`	`149`	`} else {`
`150`		`- log.error("Failed to acquire lock while closing the state store for {} task {}", taskType, id);`
	`150`	`+ log.warn("Unable to acquire lock while closing the state store for {} task {}", taskType, id);`
`151`	`151`	`}`
`152`	`152`	`} catch (final IOException e) {`
`153`	`153`	`final ProcessorStateException exception = new ProcessorStateException(`