Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-20363 Addendum wait until region is splittable

This commit is contained in:
zhangduo 2018-04-09 09:04:32 +08:00
parent c7593d14a9
commit bc35de597d
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
hbase-server/src/test/java/org/apache/hadoop/hbase/namespace/TestNamespaceAuditor.java
View File

@ -361,8 +361,14 @@ public class TestNamespaceAuditor {
hris = ADMIN.getRegions(tableTwo); hris = ADMIN.getRegions(tableTwo);
assertEquals(initialRegions - 1, hris.size()); assertEquals(initialRegions - 1, hris.size());
Collections.sort(hris, RegionInfo.COMPARATOR); Collections.sort(hris, RegionInfo.COMPARATOR);
UTIL.compact(tableTwo, true); byte[] splitKey = Bytes.toBytes("3");
ADMIN.splitRegionAsync(hris.get(0).getRegionName(), Bytes.toBytes("3")).get(10, HRegion regionToSplit = UTIL.getMiniHBaseCluster().getRegions(tableTwo).stream()
.filter(r -> r.getRegionInfo().containsRow(splitKey)).findFirst().get();
regionToSplit.compact(true);
// the above compact may quit immediately if there is a compaction ongoing, so here we need to
// wait a while to let the ongoing compaction finish.
UTIL.waitFor(10000, regionToSplit::isSplittable);
ADMIN.splitRegionAsync(regionToSplit.getRegionInfo().getRegionName(), splitKey).get(10,
TimeUnit.SECONDS); TimeUnit.SECONDS);
hris = ADMIN.getRegions(tableTwo); hris = ADMIN.getRegions(tableTwo);
assertEquals(initialRegions, hris.size()); assertEquals(initialRegions, hris.size());