You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2017/01/20 19:08:04 UTC
kafka git commit: MINOR: reduce verbosity of cache flushes
Repository: kafka
Updated Branches:
refs/heads/trunk a37bf5fff -> 50e035dc3
MINOR: reduce verbosity of cache flushes
This log message tends to be extremely verbose when state stores are being restored
Author: Xavier L�aut� <xa...@confluent.io>
Reviewers: Guozhang Wang <wa...@gmail.com>
Closes #2412 from xvrl/reduce-verbosity
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/50e035dc
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/50e035dc
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/50e035dc
Branch: refs/heads/trunk
Commit: 50e035dc341bb595decbac0851354a10c90b0e06
Parents: a37bf5f
Author: Xavier L�aut� <xa...@confluent.io>
Authored: Fri Jan 20 11:07:57 2017 -0800
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Fri Jan 20 11:07:57 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/50e035dc/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");