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 <[email protected]> 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 <[email protected]> Authored: Wed Nov 9 11:22:28 2016 -0800 Committer: Guozhang Wang <[email protected]> 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; } }
