Index: org/apache/hadoop/hbase/regionserver/HRegionServer.java =================================================================== --- org/apache/hadoop/hbase/regionserver/HRegionServer.java (revision 1134204) +++ org/apache/hadoop/hbase/regionserver/HRegionServer.java (working copy) @@ -1031,12 +1031,18 @@ */ private static class MajorCompactionChecker extends Chore { private final HRegionServer instance; + private int majorCompactPriority; MajorCompactionChecker(final HRegionServer h, final int sleepTime, final Stoppable stopper) { super("MajorCompactionChecker", sleepTime, h); this.instance = h; LOG.info("Runs every " + sleepTime + "ms"); + //default Priority set to 3 + majorCompactPriority = this.instance.conf.getInt("hbase.regionserver.compactionChecker.majorCompactPriority", + this.instance.conf.getInt("hbase.hstore.blockingStoreFiles", 7) + - this.instance.conf.getInt("hbase.hstore.compactionThreshold", 3) + -1); } @Override @@ -1046,7 +1052,7 @@ if (r != null && r.isMajorCompaction()) { // Queue a compaction. Will recognize if major is needed. this.instance.compactSplitThread.requestCompaction(r, getName() - + " requests major compaction"); + + " requests major compaction", this.majorCompactPriority); } } catch (IOException e) { LOG.warn("Failed major compaction check on " + r, e);