This is an automated email from the ASF dual-hosted git repository.
ableegoldman pushed a commit to branch 3.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/3.0 by this push:
new 0707a8d KAFKA-13037: "Thread state is already PENDING_SHUTDOWN" log
spam
0707a8d is described below
commit 0707a8d31b4d0054619d656144156a3aab1053fc
Author: John Gray <[email protected]>
AuthorDate: Wed Jul 14 00:00:23 2021 -0400
KAFKA-13037: "Thread state is already PENDING_SHUTDOWN" log spam
Demote this from INFO to debug since it's absolutely spamming the logs
Reviewers: Anna Sophie Blee-Goldman <[email protected]>
---
.../java/org/apache/kafka/streams/processor/internals/StreamThread.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
index 6c9cbeb..224733e 100644
---
a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
+++
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
@@ -724,7 +724,7 @@ public class StreamThread extends Thread {
// Should only proceed when the thread is still running after
#pollRequests(), because no external state mutation
// could affect the task manager state beyond this point within
#runOnce().
if (!isRunning()) {
- log.info("Thread state is already {}, skipping the run once call
after poll request", state);
+ log.debug("Thread state is already {}, skipping the run once call
after poll request", state);
return;
}
