diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/HBaseTestingUtility.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/HBaseTestingUtility.java index f67fece8aee..353a48dce28 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/HBaseTestingUtility.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/HBaseTestingUtility.java @@ -1467,7 +1467,6 @@ public class HBaseTestingUtility extends HBaseZKTestingUtility { /** * Flushes all caches in the mini hbase cluster - * @throws IOException */ public void flush() throws IOException { getMiniHBaseCluster().flushcache(); @@ -1475,7 +1474,6 @@ public class HBaseTestingUtility extends HBaseZKTestingUtility { /** * Flushes all caches in the mini hbase cluster - * @throws IOException */ public void flush(TableName tableName) throws IOException { getMiniHBaseCluster().flushcache(tableName); @@ -1483,7 +1481,6 @@ public class HBaseTestingUtility extends HBaseZKTestingUtility { /** * Compact all regions in the mini hbase cluster - * @throws IOException */ public void compact(boolean major) throws IOException { getMiniHBaseCluster().compact(major); @@ -1491,7 +1488,6 @@ public class HBaseTestingUtility extends HBaseZKTestingUtility { /** * Compact all of a table's reagion in the mini hbase cluster - * @throws IOException */ public void compact(TableName tableName, boolean major) throws IOException { getMiniHBaseCluster().compact(tableName, major); diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/MiniHBaseCluster.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/MiniHBaseCluster.java index 4b2886e5007..b5339d72012 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/MiniHBaseCluster.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/MiniHBaseCluster.java @@ -24,9 +24,9 @@ import java.util.ArrayList; import java.util.HashSet; import java.util.List; import java.util.Set; - import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileSystem; +import org.apache.hadoop.hbase.client.RegionReplicaUtil; import org.apache.hadoop.hbase.master.HMaster; import org.apache.hadoop.hbase.regionserver.HRegion; import org.apache.hadoop.hbase.regionserver.HRegion.FlushResult; @@ -728,6 +728,9 @@ public class MiniHBaseCluster extends HBaseCluster { } private void executeFlush(HRegion region) throws IOException { + if (!RegionReplicaUtil.isDefaultReplica(region.getRegionInfo())) { + return; + } // retry 5 times if we can not flush for (int i = 0; i < 5; i++) { FlushResult result = region.flush(true); @@ -767,10 +770,11 @@ public class MiniHBaseCluster extends HBaseCluster { * @throws IOException */ public void compact(boolean major) throws IOException { - for (JVMClusterUtil.RegionServerThread t: - this.hbaseCluster.getRegionServers()) { - for(HRegion r: t.getRegionServer().getOnlineRegionsLocalContext()) { - r.compact(major); + for (JVMClusterUtil.RegionServerThread t : this.hbaseCluster.getRegionServers()) { + for (HRegion r : t.getRegionServer().getOnlineRegionsLocalContext()) { + if (RegionReplicaUtil.isDefaultReplica(r.getRegionInfo())) { + r.compact(major); + } } } } @@ -780,11 +784,12 @@ public class MiniHBaseCluster extends HBaseCluster { * @throws IOException */ public void compact(TableName tableName, boolean major) throws IOException { - for (JVMClusterUtil.RegionServerThread t: - this.hbaseCluster.getRegionServers()) { - for(HRegion r: t.getRegionServer().getOnlineRegionsLocalContext()) { - if(r.getTableDescriptor().getTableName().equals(tableName)) { - r.compact(major); + for (JVMClusterUtil.RegionServerThread t : this.hbaseCluster.getRegionServers()) { + for (HRegion r : t.getRegionServer().getOnlineRegionsLocalContext()) { + if (r.getTableDescriptor().getTableName().equals(tableName)) { + if (RegionReplicaUtil.isDefaultReplica(r.getRegionInfo())) { + r.compact(major); + } } } }