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: reduce amount of verbose printing
Date Thu, 30 Mar 2017 20:47:16 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 92b7d7570 -> f9772d5fb


MINOR: reduce amount of verbose printing

Author: Eno Thereska <eno@confluent.io>

Reviewers: Guozhang Wang <wangguoz@gmail.com>

Closes #2764 from enothereska/minor-remove-verboseprint


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

Branch: refs/heads/trunk
Commit: f9772d5fb26b0a375729a88db5e7ee199f85c8b3
Parents: 92b7d75
Author: Eno Thereska <eno@confluent.io>
Authored: Thu Mar 30 13:47:11 2017 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Thu Mar 30 13:47:11 2017 -0700

----------------------------------------------------------------------
 .../kafka/streams/processor/internals/StreamThread.java | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/f9772d5f/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 b90bde5..46704b9 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
@@ -756,7 +756,7 @@ public class StreamThread extends Thread {
         if (commitTimeMs >= 0 && lastCommitMs + commitTimeMs < now) {
 
             log.info("{} Committing all active tasks {} and standby tasks {} because the
commit interval {}ms has elapsed by {}ms",
-                    logPrefix, activeTasks, standbyTasks, commitTimeMs, now - lastCommitMs);
+                    logPrefix, activeTasks.keySet(), standbyTasks.keySet(), commitTimeMs,
now - lastCommitMs);
 
             commitAll();
             lastCommitMs = now;
@@ -1279,8 +1279,8 @@ public class StreamThread extends Thread {
                             "\tcurrent suspended standby tasks: {}\n" +
                             "\tprevious active tasks: {}",
                     logPrefix, state, assignment,
-                    partitionAssignor.activeTasks(), partitionAssignor.standbyTasks(),
-                    suspendedTasks, suspendedStandbyTasks, prevActiveTasks);
+                    partitionAssignor.activeTasks().keySet(), partitionAssignor.standbyTasks().keySet(),
+                    suspendedTasks.keySet(), suspendedStandbyTasks.keySet(), prevActiveTasks);
 
             final long start = time.milliseconds();
             try {
@@ -1304,7 +1304,7 @@ public class StreamThread extends Thread {
                         "\tcurrent active tasks: {}\n" +
                         "\tcurrent standby tasks: {}",
                         logPrefix, time.milliseconds() - start,
-                        activeTasks, standbyTasks);
+                        activeTasks.keySet(), standbyTasks.keySet());
             }
         }
 
@@ -1314,7 +1314,7 @@ public class StreamThread extends Thread {
                             "\tcurrent assigned active tasks: {}\n" +
                             "\tcurrent assigned standby tasks: {}\n",
                     logPrefix, state, assignment,
-                    activeTasks, standbyTasks);
+                    activeTasks.keySet(), standbyTasks.keySet());
 
             final long start = time.milliseconds();
             try {
@@ -1335,7 +1335,7 @@ public class StreamThread extends Thread {
                                 "\tsuspended standby tasks: {}\n" +
                                 "\tprevious active tasks: {}\n",
                         logPrefix, time.milliseconds() - start,
-                        suspendedTasks, suspendedStandbyTasks, prevActiveTasks);
+                        suspendedTasks.keySet(), suspendedStandbyTasks.keySet(), prevActiveTasks);
             }
         }
     }


Mime
View raw message