diff --git hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/ExploringCompactionPolicy.java hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/ExploringCompactionPolicy.java index dbd4adb..b0874b4 100644 --- hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/ExploringCompactionPolicy.java +++ hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/ExploringCompactionPolicy.java @@ -96,13 +96,8 @@ public class ExploringCompactionPolicy extends RatioBasedCompactionPolicy { smallestSize = size; } - if (size > comConf.getMaxCompactSize()) { - continue; - } - ++opts; - if (size >= comConf.getMinCompactSize() - && !filesInRatio(potentialMatchFiles, currentRatio)) { + if (!filesInRatio(potentialMatchFiles, currentRatio)) { continue; } @@ -169,11 +164,11 @@ public class ExploringCompactionPolicy extends RatioBasedCompactionPolicy { } long totalFileSize = getTotalStoreSize(files); - + long minSize = comConf.getMinCompactSize(); for (StoreFile file : files) { long singleFileSize = file.getReader().length(); + if(singleFileSize < minSize) continue; long sumAllOtherFileSizes = totalFileSize - singleFileSize; - if (singleFileSize > sumAllOtherFileSizes * currentRatio) { return false; }