svn commit: r1809822 - /jackrabbit/oak/trunk/oak-lucene/src/main/java/org/apache/jackrabbit/oak/plugins/index/lucene/writer/CommitMitigatingTieredMergePolicy.java

[tommaso]

Author: tommaso
Date: Wed Sep 27 09:56:31 2017
New Revision: 1809822

URL: http://svn.apache.org/viewvc?rev=1809822&view=rev
Log:
OAK-6710 - added debug log for commit rates

Modified:
    
jackrabbit/oak/trunk/oak-lucene/src/main/java/org/apache/jackrabbit/oak/plugins/index/lucene/writer/CommitMitigatingTieredMergePolicy.java

Modified: 
jackrabbit/oak/trunk/oak-lucene/src/main/java/org/apache/jackrabbit/oak/plugins/index/lucene/writer/CommitMitigatingTieredMergePolicy.java
URL: 
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-lucene/src/main/java/org/apache/jackrabbit/oak/plugins/index/lucene/writer/CommitMitigatingTieredMergePolicy.java?rev=1809822&r1=1809821&r2=1809822&view=diff
==============================================================================
--- 
jackrabbit/oak/trunk/oak-lucene/src/main/java/org/apache/jackrabbit/oak/plugins/index/lucene/writer/CommitMitigatingTieredMergePolicy.java
 (original)
+++ 
jackrabbit/oak/trunk/oak-lucene/src/main/java/org/apache/jackrabbit/oak/plugins/index/lucene/writer/CommitMitigatingTieredMergePolicy.java
 Wed Sep 27 09:56:31 2017
@@ -30,6 +30,8 @@ import org.apache.lucene.index.IndexWrit
 import org.apache.lucene.index.MergePolicy;
 import org.apache.lucene.index.SegmentCommitInfo;
 import org.apache.lucene.index.SegmentInfos;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  *  This {@link MergePolicy} extends Lucene's {@link 
org.apache.lucene.index.TieredMergePolicy} by providing mitigation
@@ -42,12 +44,15 @@ import org.apache.lucene.index.SegmentIn
  *
  */
 public class CommitMitigatingTieredMergePolicy extends MergePolicy {
+
+    private final Logger log = LoggerFactory.getLogger(getClass());
+
     /** Default noCFSRatio.  If a merge's size is >= 10% of
      *  the index, then we disable compound file for it.
      *  @see MergePolicy#setNoCFSRatio */
     public static final double DEFAULT_NO_CFS_RATIO = 0.1;
 
-    public static final double DEFAULT_MAX_COMMIT_RATE_DOCS = 1000;
+    private static final double DEFAULT_MAX_COMMIT_RATE_DOCS = 1000;
     private static final double DEFAULT_MAX_COMMIT_RATE_MB = 5;
 
     private int maxMergeAtOnce = 10;
@@ -61,6 +66,7 @@ public class CommitMitigatingTieredMerge
 
     private double maxCommitRateDocs = DEFAULT_MAX_COMMIT_RATE_DOCS;
     private double maxCommitRateMB = DEFAULT_MAX_COMMIT_RATE_MB;
+
     private double docCount = 0d;
     private double mb = 0d;
     private double time = System.currentTimeMillis();
@@ -271,6 +277,7 @@ public class CommitMitigatingTieredMerge
         long now = System.currentTimeMillis();
         double timeDelta = (now / 1000d) - (time / 1000d);
         double commitRate = Math.abs(docCount - infos.totalDocCount()) / 
timeDelta;
+        log.debug("committing {} docs/sec", commitRate);
 
         docCount = infos.totalDocCount();
         time = now;
@@ -370,6 +377,7 @@ public class CommitMitigatingTieredMerge
 
             double bytes = idxBytes - this.mb;
             double mbRate = bytes / timeDelta;
+            log.debug("committing {} MBs/sec", mbRate);
 
             if (verbose()) {
                 message(mbRate + "mb/s (max: " + maxCommitRateMB + "mb/s)");