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

HBASE-26805 Addendum forward port the test improvements in HBASE-26304 for branch-2

This commit is contained in:
Duo Zhang 2022-03-07 08:16:21 +08:00
parent 480db06e46
commit 19ad3d6654
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
hbase-balancer/src/test/java/org/apache/hadoop/hbase/master/balancer/TestRegionHDFSBlockLocationFinder.java
View File

@ -231,9 +231,17 @@ public class TestRegionHDFSBlockLocationFinder {
finder.setClusterMetrics(getMetricsWithLocality(testServer, testRegion.getRegionName(), finder.setClusterMetrics(getMetricsWithLocality(testServer, testRegion.getRegionName(),
0.345f)); 0.345f));
// there is no way to test whether the refresh for a guava cache is finished, so here we just
// add a one second sleep, usually this is enough for the refresh // cache refresh happens in a background thread, so we need to wait for the value to
Thread.sleep(1000); // update before running assertions.
long now = System.currentTimeMillis();
HDFSBlocksDistribution cached = cache.get(testRegion);
HDFSBlocksDistribution newValue;
do {
Thread.sleep(1_000);
newValue = finder.getBlockDistribution(testRegion);
} while (cached == newValue && System.currentTimeMillis() - now < 30_000);
// locality changed just for our test region, so it should no longer be the same // locality changed just for our test region, so it should no longer be the same
for (RegionInfo region : REGIONS) { for (RegionInfo region : REGIONS) {
HDFSBlocksDistribution hbd = finder.getBlockDistribution(region); HDFSBlocksDistribution hbd = finder.getBlockDistribution(region);