kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From damian...@apache.org
Subject kafka git commit: MINOR: change task initialization logging levels
Date Wed, 20 Sep 2017 11:07:08 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 37ec15e96 -> bb9859720


MINOR: change task initialization logging levels

In `AssignedTasks` log at debug all task ids that are yet to be initialized.
In `StreamsTask` log at trace when the task is initialized.

Author: Damian Guy <damian.guy@gmail.com>

Reviewers: Guozhang Wang <wangguoz@gmail.com>

Closes #3905 from dguy/minor-task-init-logging


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/bb985972
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/bb985972
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/bb985972

Branch: refs/heads/trunk
Commit: bb9859720bf88732cb63ec27cfa10d510d767d2b
Parents: 37ec15e
Author: Damian Guy <damian.guy@gmail.com>
Authored: Wed Sep 20 12:07:04 2017 +0100
Committer: Damian Guy <damian.guy@gmail.com>
Committed: Wed Sep 20 12:07:04 2017 +0100

----------------------------------------------------------------------
 .../apache/kafka/streams/processor/internals/AssignedTasks.java   | 2 +-
 .../org/apache/kafka/streams/processor/internals/StreamTask.java  | 3 +--
 2 files changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/bb985972/streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedTasks.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedTasks.java
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedTasks.java
index 3208f93..e51ebd7 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedTasks.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/AssignedTasks.java
@@ -109,7 +109,7 @@ class AssignedTasks {
 
     void initializeNewTasks() {
         if (!created.isEmpty()) {
-            log.trace("Initializing {}s {}", taskTypeName, created.keySet());
+            log.debug("Initializing {}s {}", taskTypeName, created.keySet());
         }
         for (final Iterator<Map.Entry<TaskId, Task>> it = created.entrySet().iterator();
it.hasNext(); ) {
             final Map.Entry<TaskId, Task> entry = it.next();

http://git-wip-us.apache.org/repos/asf/kafka/blob/bb985972/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
index 0830aa2..6775edb 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
@@ -152,7 +152,7 @@ public class StreamTask extends AbstractTask implements ProcessorNodePunctuator
     }
 
     public boolean initialize() {
-        log.debug("Initializing");
+        log.trace("Initializing");
         initializeStateStores();
         initTopology();
         processorContext.initialized();
@@ -606,5 +606,4 @@ public class StreamTask extends AbstractTask implements ProcessorNodePunctuator
     RecordCollector createRecordCollector(final LogContext logContext) {
         return new RecordCollectorImpl(producer, id.toString(), logContext);
     }
-
 }


Mime
View raw message