kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR: fix incorrect logging in StreamThread
Date Wed, 09 Nov 2016 19:22:32 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk f1e1b6e74 -> a66ca1624


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 <damian.guy@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/a66ca162
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/a66ca162
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/a66ca162

Branch: refs/heads/trunk
Commit: a66ca1624c692d30b7ae1e25c29915331cbf41e3
Parents: f1e1b6e
Author: Damian Guy <damian.guy@gmail.com>
Authored: Wed Nov 9 11:22:28 2016 -0800
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Wed Nov 9 11:22: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/a66ca162/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 fa5b5f1..1cd8a39 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
@@ -713,7 +713,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;
                 }
             } else {


Mime
View raw message