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

HBASE-23853 [Flakey Test] TestBlockEvictionFromClient#testBlockRefCountAfterSplits 

ADDENDUM MORE: Add logging of all blocks in cache
This commit is contained in:
stack 2020-02-17 20:43:21 -08:00
parent 3895919e10
commit 92411ad3dd
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestBlockEvictionFromClient.java
View File

@ -583,7 +583,7 @@ public class TestBlockEvictionFromClient {
region.flush(true);
ServerName rs = Iterables.getOnlyElement(TEST_UTIL.getAdmin().getRegionServers());
int regionCount = TEST_UTIL.getAdmin().getRegions(rs).size();
LOG.info("About to SPLIT on {}", Bytes.toString(ROW1));
LOG.info("About to SPLIT on {} {}", Bytes.toString(ROW1), region.getRegionInfo());
TEST_UTIL.getAdmin().split(tableName, ROW1);
// Wait for splits
TEST_UTIL.waitFor(60000, () -> TEST_UTIL.getAdmin().getRegions(rs).size() > regionCount);
@ -1189,8 +1189,10 @@ public class TestBlockEvictionFromClient {
CachedBlock next = iterator.next();
BlockCacheKey cacheKey = new BlockCacheKey(next.getFilename(), next.getOffset());
if (cache instanceof BucketCache) {
LOG.info("BucketCache {}", cacheKey);
refCount = ((BucketCache) cache).getRpcRefCount(cacheKey);
} else if (cache instanceof CombinedBlockCache) {
LOG.info("CombinedBlockCache {}", cacheKey);
refCount = ((CombinedBlockCache) cache).getRpcRefCount(cacheKey);
} else {
continue;