You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2020/02/11 23:00:04 UTC
[kafka] branch 2.4 updated: KAFKA-9540: Move "Could not find the
standby task while closing it" log to debug level (#8092)
This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a commit to branch 2.4
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.4 by this push:
new 2b3a537 KAFKA-9540: Move "Could not find the standby task while closing it" log to debug level (#8092)
2b3a537 is described below
commit 2b3a5379fdb1217e9156a93896bbf07540b3f117
Author: A. Sophie Blee-Goldman <so...@confluent.io>
AuthorDate: Tue Feb 11 14:59:36 2020 -0800
KAFKA-9540: Move "Could not find the standby task while closing it" log to debug level (#8092)
Reviewers: Guozhang Wang <wa...@gmail.com>
---
.../apache/kafka/streams/processor/internals/AssignedStandbyTasks.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedStandbyTasks.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedStandbyTasks.java
index 299390b..ba41fd8 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedStandbyTasks.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedStandbyTasks.java
@@ -71,7 +71,8 @@ class AssignedStandbyTasks extends AssignedTasks<StandbyTask> {
} else if (created.containsKey(taskId)) {
task = created.get(taskId);
} else {
- log.error("Could not find the standby task {} while closing it", taskId);
+ log.debug("Could not find the standby task {} while closing it, most likely it was not created " +
+ "because it has no state stores in its subtopology.", taskId);
continue;
}