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

[tommaso]

Author: tommaso
Date: Thu Nov  2 13:32:28 2017
New Revision: 1814078

URL: http://svn.apache.org/viewvc?rev=1814078&view=rev
Log:
OAK-6710 - added debug log for adjusted max 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=1814078&r1=1814077&r2=1814078&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
 Thu Nov  2 13:32:28 2017
@@ -386,10 +386,14 @@ public class CommitMitigatingTieredMerge
         // if no. of segments exceeds the maximum, adjust the maximum rates to 
allow more merges (less commit/rate mitigation)
         if (segmentSize > maxNoOfSegsForMitigation) {
             if (avgCommitRateDocs > maxCommitRateDocs) {
-                maxCommitRateDocs = singleExpSmoothing(avgCommitRateDocs, 
maxCommitRateDocs);
+                double v = singleExpSmoothing(avgCommitRateDocs, 
maxCommitRateDocs);
+                log.debug("adjusted maxCommitRateDocs from {} to {}", 
maxCommitRateDocs, v);
+                maxCommitRateDocs = v;
             }
             if (avgCommitRateMB > maxCommitRateMB) {
-                maxCommitRateMB = singleExpSmoothing(avgCommitRateMB, 
maxCommitRateMB);
+                double v = singleExpSmoothing(avgCommitRateMB, 
maxCommitRateMB);
+                log.debug("adjusted maxCommitRateMB from {} to {}", 
maxCommitRateMB, v);
+                maxCommitRateMB = v;
             }
         }