From 5e65f679071250e727e1e1cc3918ac63a26837e3 Mon Sep 17 00:00:00 2001 From: rahulgidwani Date: Wed, 18 Mar 2015 13:51:28 -0700 Subject: [PATCH] Major bug in HBASE-11195 where we could potentially always major compact --- .../hbase/regionserver/compactions/RatioBasedCompactionPolicy.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/RatioBasedCompactionPolicy.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/RatioBasedCompactionPolicy.java index 8b227f5..f1c04d4 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/RatioBasedCompactionPolicy.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/RatioBasedCompactionPolicy.java @@ -300,7 +300,7 @@ public class RatioBasedCompactionPolicy extends CompactionPolicy { (cfTtl == HConstants.FOREVER || oldest < cfTtl)) { float blockLocalityIndex = sf.getHDFSBlockDistribution() .getBlockLocalityIndex(HRegionServer.getHostname(comConf.conf)); - if (blockLocalityIndex > comConf.getMinLocalityToForceCompact()) { + if (blockLocalityIndex < comConf.getMinLocalityToForceCompact()) { if (LOG.isDebugEnabled()) { LOG.debug("Major compaction triggered on only store " + this + "; to make hdfs blocks local, current blockLocalityIndex is " + -- 2.1.0