HBASE-27365 Minimise block addition failures due to no space in bucket cache writers queue by introducing wait time - addendum fixing the test case failure
This commit is contained in:
parent
eb6b2745c5
commit
5ffb29688d
|
@ -813,11 +813,6 @@ public class TestBucketCache {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* This test is for HBASE-26295, {@link BucketEntry} which is restored from a persistence file
|
|
||||||
* could not be freed even if corresponding {@link HFileBlock} is evicted from
|
|
||||||
* {@link BucketCache}.
|
|
||||||
*/
|
|
||||||
@Test
|
@Test
|
||||||
public void testBlockAdditionWaitWhenCache() throws Exception {
|
public void testBlockAdditionWaitWhenCache() throws Exception {
|
||||||
try {
|
try {
|
||||||
|
@ -845,7 +840,7 @@ public class TestBucketCache {
|
||||||
while (bucketCache.backingMap.size() != 10) {
|
while (bucketCache.backingMap.size() != 10) {
|
||||||
if (timeout <= 0) break;
|
if (timeout <= 0) break;
|
||||||
Threads.sleep(100);
|
Threads.sleep(100);
|
||||||
timeout = -100;
|
timeout -= 100;
|
||||||
}
|
}
|
||||||
for (HFileBlockPair hfileBlockPair : hfileBlockPairs) {
|
for (HFileBlockPair hfileBlockPair : hfileBlockPairs) {
|
||||||
assertTrue(bucketCache.backingMap.containsKey(hfileBlockPair.getBlockName()));
|
assertTrue(bucketCache.backingMap.containsKey(hfileBlockPair.getBlockName()));
|
||||||
|
|
Loading…
Reference in New Issue