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 2016/11/24 05:10:54 UTC
[2/4] kafka git commit: MINOR: fix incorrect logging in StreamThread
MINOR: fix incorrect logging in StreamThread
Fix incorrect logging when unable to create an active task. The output was: Failed to create an active task %s:
It should have the taskId.
Author: Damian Guy <da...@gmail.com>
Reviewers: Ismael Juma, Eno Thereska
Closes #2109 from dguy/minor-logging
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/c000eb22
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/c000eb22
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/c000eb22
Branch: refs/heads/0.10.1
Commit: c000eb22ae82184f3ec2bfeb91609bef7a1e875d
Parents: c1fb615
Author: Damian Guy <da...@gmail.com>
Authored: Wed Nov 9 11:22:28 2016 -0800
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Wed Nov 23 08:51:28 2016 -0800
----------------------------------------------------------------------
.../org/apache/kafka/streams/processor/internals/StreamThread.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/c000eb22/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
----------------------------------------------------------------------
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 d7bb98c..8b7478d 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
@@ -663,7 +663,7 @@ public class StreamThread extends Thread {
for (TopicPartition partition : partitions)
activeTasksByPartition.put(partition, task);
} catch (StreamsException e) {
- log.error("{} Failed to create an active task %s: ", logPrefix, taskId, e);
+ log.error("{} Failed to create an active task {}: ", logPrefix, taskId, e);
throw e;
}
}