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 verbosity of cache flushes
Date Fri, 20 Jan 2017 19:08:12 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.2 3e1abac4c -> 05237367d


MINOR: reduce verbosity of cache flushes

This log message tends to be extremely verbose when state stores are being restored

Author: Xavier Léauté <xavier@confluent.io>

Reviewers: Guozhang Wang <wangguoz@gmail.com>

Closes #2412 from xvrl/reduce-verbosity

(cherry picked from commit 50e035dc341bb595decbac0851354a10c90b0e06)
Signed-off-by: Guozhang Wang <wangguoz@gmail.com>


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

Branch: refs/heads/0.10.2
Commit: 05237367d7a12f395c9b2a1c2b354e1564f21aae
Parents: 3e1abac
Author: Xavier Léauté <xavier@confluent.io>
Authored: Fri Jan 20 11:07:57 2017 -0800
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Fri Jan 20 11:08:08 2017 -0800

----------------------------------------------------------------------
 .../org/apache/kafka/streams/state/internals/NamedCache.java   | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/05237367/streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java
b/streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java
index 6dc08f2..229ccec 100644
--- a/streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java
+++ b/streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java
@@ -106,8 +106,10 @@ class NamedCache {
     private void flush(final LRUNode evicted) {
         numFlushes++;
 
-        log.debug("Named cache {} stats on flush: #hits={}, #misses={}, #overwrites={}, #flushes={}",
-                  name, hits(), misses(), overwrites(), flushes());
+        if (log.isTraceEnabled()) {
+            log.trace("Named cache {} stats on flush: #hits={}, #misses={}, #overwrites={},
#flushes={}",
+                      name, hits(), misses(), overwrites(), flushes());
+        }
 
         if (listener == null) {
             throw new IllegalArgumentException("No listener for namespace " + name + " registered
with cache");


Mime
View raw message