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

HBASE-20036 TestAvoidCellReferencesIntoShippedBlocks timed out (Ram)

This commit is contained in:
Vasudevan 2018-02-26 22:07:42 +05:30
parent a29b3caf4d
commit 7cfb46432f
1 changed files with 17 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestAvoidCellReferencesIntoShippedBlocks.java
View File

@ -400,23 +400,27 @@ public class TestAvoidCellReferencesIntoShippedBlocks {
scanner = table.getScanner(s1); scanner = table.getScanner(s1);
int count = Iterables.size(scanner); int count = Iterables.size(scanner);
assertEquals("Count the rows", 2, count); assertEquals("Count the rows", 2, count);
iterator = cache.iterator();
List<BlockCacheKey> newCacheList = new ArrayList<>();
while (iterator.hasNext()) {
CachedBlock next = iterator.next();
BlockCacheKey cacheKey = new BlockCacheKey(next.getFilename(), next.getOffset());
newCacheList.add(cacheKey);
}
int newBlockRefCount = 0; int newBlockRefCount = 0;
for (BlockCacheKey key : cacheList) { List<BlockCacheKey> newCacheList = new ArrayList<>();
if (newCacheList.contains(key)) { while (true) {
newBlockRefCount++; newBlockRefCount = 0;
newCacheList.clear();
iterator = cache.iterator();
while (iterator.hasNext()) {
CachedBlock next = iterator.next();
BlockCacheKey cacheKey = new BlockCacheKey(next.getFilename(), next.getOffset());
newCacheList.add(cacheKey);
}
for (BlockCacheKey key : cacheList) {
if (newCacheList.contains(key)) {
newBlockRefCount++;
}
}
if (newBlockRefCount == 6) {
break;
} }
} }
assertEquals("old blocks should still be found ", 6, newBlockRefCount);
latch.countDown(); latch.countDown();
} catch (IOException e) { } catch (IOException e) {
} }
} }