From 92411ad3ddd75eabe31a00c07fa561079d85e639 Mon Sep 17 00:00:00 2001 From: stack Date: Mon, 17 Feb 2020 20:43:21 -0800 Subject: [PATCH] HBASE-23853 [Flakey Test] TestBlockEvictionFromClient#testBlockRefCountAfterSplits ADDENDUM MORE: Add logging of all blocks in cache --- .../hadoop/hbase/client/TestBlockEvictionFromClient.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestBlockEvictionFromClient.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestBlockEvictionFromClient.java index 03b566e9646..c243c4ac897 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestBlockEvictionFromClient.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestBlockEvictionFromClient.java @@ -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;