This is an automated email from the ASF dual-hosted git repository.
wchevreuil pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/master by this push:
new aea7e7c85cd [ADDENDUM] HBASE-28458
BucketCache.notifyFileCachingCompleted may incorrectly consider a file fully
cached (#5777) (#5791)
aea7e7c85cd is described below
commit aea7e7c85cdb8628fb03ead0f94d8e07ad49f067
Author: Wellington Ramos Chevreuil <wchevre...@apache.org>
AuthorDate: Fri Apr 5 10:56:06 2024 +0100
[ADDENDUM] HBASE-28458 BucketCache.notifyFileCachingCompleted may
incorrectly consider a file fully cached (#5777) (#5791)
Signed-off-by: Peter Somogyi <psomo...@apache.org>
---
.../hadoop/hbase/io/hfile/bucket/BucketCache.java | 46 +++++++++++++++-------
.../io/hfile/bucket/TestPrefetchPersistence.java | 35 +++-------------
2 files changed, 36 insertions(+), 45 deletions(-)
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.java
index 9541939db94..71bfc757e51 100644
---
a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.java
+++
b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.java
@@ -747,7 +747,8 @@ public class BucketCache implements BlockCache, HeapSize {
} else {
return bucketEntryToUse.withWriteLock(offsetLock, () -> {
if (backingMap.remove(cacheKey, bucketEntryToUse)) {
- LOG.debug("removed key {} from back map in the evict process",
cacheKey);
+ LOG.debug("removed key {} from back map with offset lock {} in the
evict process",
+ cacheKey, bucketEntryToUse.offset());
blockEvicted(cacheKey, bucketEntryToUse, !existedInRamCache,
evictedByEvictionProcess);
return true;
}
@@ -1658,19 +1659,21 @@ public class BucketCache implements BlockCache,
HeapSize {
@Override
public int evictBlocksByHfileName(String hfileName) {
fileNotFullyCached(hfileName);
- Set<BlockCacheKey> keySet = blocksByHFile.subSet(new
BlockCacheKey(hfileName, Long.MIN_VALUE),
- true, new BlockCacheKey(hfileName, Long.MAX_VALUE), true);
-
+ Set<BlockCacheKey> keySet = getAllCacheKeysForFile(hfileName);
int numEvicted = 0;
for (BlockCacheKey key : keySet) {
if (evictBlock(key)) {
++numEvicted;
}
}
-
return numEvicted;
}
+ private Set<BlockCacheKey> getAllCacheKeysForFile(String hfileName) {
+ return blocksByHFile.subSet(new BlockCacheKey(hfileName, Long.MIN_VALUE),
true,
+ new BlockCacheKey(hfileName, Long.MAX_VALUE), true);
+ }
+
/**
* Used to group bucket entries into priority buckets. There will be a
BucketEntryGroup for each
* priority (single, multi, memory). Once bucketed, the eviction algorithm
takes the appropriate
@@ -2083,25 +2086,32 @@ public class BucketCache implements BlockCache,
HeapSize {
entry.getKey().getHfileName().equals(fileName.getName())
&& entry.getKey().getBlockType().equals(BlockType.DATA)
) {
- LOG.debug("found block for file {} in the backing map. Acquiring
read lock for offset {}",
- fileName, entry.getKey().getOffset());
- ReentrantReadWriteLock lock =
offsetLock.getLock(entry.getKey().getOffset());
+ long offsetToLock = entry.getValue().offset();
+ LOG.debug("found block {} in the backing map. Acquiring read lock
for offset {}",
+ entry.getKey(), offsetToLock);
+ ReentrantReadWriteLock lock = offsetLock.getLock(offsetToLock);
lock.readLock().lock();
locks.add(lock);
// rechecks the given key is still there (no eviction happened
before the lock acquired)
if (backingMap.containsKey(entry.getKey())) {
count.increment();
+ } else {
+ lock.readLock().unlock();
+ locks.remove(lock);
+ LOG.debug("found block {}, but when locked and tried to count, it
was gone.");
}
}
});
+ int metaCount = totalBlockCount - dataBlockCount;
// BucketCache would only have data blocks
if (dataBlockCount == count.getValue()) {
LOG.debug("File {} has now been fully cached.", fileName);
fileCacheCompleted(fileName, size);
} else {
LOG.debug(
- "Prefetch executor completed for {}, but only {} blocks were cached.
"
- + "Total blocks for file: {}. Checking for blocks pending cache in
cache writer queue.",
+ "Prefetch executor completed for {}, but only {} data blocks were
cached. "
+ + "Total data blocks for file: {}. "
+ + "Checking for blocks pending cache in cache writer queue.",
fileName, count.getValue(), dataBlockCount);
if (ramCache.hasBlocksForFile(fileName.getName())) {
for (ReentrantReadWriteLock lock : locks) {
@@ -2111,11 +2121,17 @@ public class BucketCache implements BlockCache,
HeapSize {
+ "and try the verification again.", fileName);
Thread.sleep(100);
notifyFileCachingCompleted(fileName, totalBlockCount,
dataBlockCount, size);
- } else {
- LOG.info("We found only {} blocks cached from a total of {} for file
{}, "
- + "but no blocks pending caching. Maybe cache is full or evictions
"
- + "happened concurrently to cache prefetch.", count,
totalBlockCount, fileName);
- }
+ } else
+ if ((getAllCacheKeysForFile(fileName.getName()).size() - metaCount)
== dataBlockCount) {
+ LOG.debug("We counted {} data blocks, expected was {}, there was
no more pending in "
+ + "the cache write queue but we now found that total cached
blocks for file {} "
+ + "is equal to data block count.", count, dataBlockCount,
fileName.getName());
+ fileCacheCompleted(fileName, size);
+ } else {
+ LOG.info("We found only {} data blocks cached from a total of {}
for file {}, "
+ + "but no blocks pending caching. Maybe cache is full or
evictions "
+ + "happened concurrently to cache prefetch.", count,
dataBlockCount, fileName);
+ }
}
} catch (InterruptedException e) {
throw new RuntimeException(e);
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/bucket/TestPrefetchPersistence.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/bucket/TestPrefetchPersistence.java
index 035cdc3f887..4da2d5af923 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/bucket/TestPrefetchPersistence.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/bucket/TestPrefetchPersistence.java
@@ -18,7 +18,6 @@
package org.apache.hadoop.hbase.io.hfile.bucket;
import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertNotEquals;
import static org.junit.Assert.assertTrue;
@@ -34,11 +33,8 @@ import org.apache.hadoop.hbase.HBaseClassTestRule;
import org.apache.hadoop.hbase.HBaseTestingUtil;
import org.apache.hadoop.hbase.KeyValue;
import org.apache.hadoop.hbase.fs.HFileSystem;
-import org.apache.hadoop.hbase.io.hfile.BlockCacheKey;
-import org.apache.hadoop.hbase.io.hfile.BlockType;
import org.apache.hadoop.hbase.io.hfile.CacheConfig;
import org.apache.hadoop.hbase.io.hfile.HFile;
-import org.apache.hadoop.hbase.io.hfile.HFileBlock;
import org.apache.hadoop.hbase.io.hfile.HFileContext;
import org.apache.hadoop.hbase.io.hfile.HFileContextBuilder;
import org.apache.hadoop.hbase.io.hfile.RandomKeyValueUtil;
@@ -121,8 +117,8 @@ public class TestPrefetchPersistence {
// Load Cache
Path storeFile = writeStoreFile("TestPrefetch0");
Path storeFile2 = writeStoreFile("TestPrefetch1");
- readStoreFile(storeFile, 0);
- readStoreFile(storeFile2, 0);
+ readStoreFile(storeFile);
+ readStoreFile(storeFile2);
usedSize = bucketCache.getAllocator().getUsedSize();
assertNotEquals(0, usedSize);
@@ -133,39 +129,18 @@ public class TestPrefetchPersistence {
testDir + "/bucket.persistence", 60 * 1000, conf);
cacheConf = new CacheConfig(conf, bucketCache);
assertTrue(usedSize != 0);
- readStoreFile(storeFile, 0);
- readStoreFile(storeFile2, 0);
- // Test Close Store File
- closeStoreFile(storeFile2);
+ assertTrue(bucketCache.fullyCachedFiles.containsKey(storeFile.getName()));
+ assertTrue(bucketCache.fullyCachedFiles.containsKey(storeFile2.getName()));
TEST_UTIL.cleanupTestDir();
}
- public void closeStoreFile(Path path) throws Exception {
- HFile.Reader reader = HFile.createReader(fs, path, cacheConf, true, conf);
- assertTrue(bucketCache.fullyCachedFiles.containsKey(path.getName()));
- reader.close(true);
- assertFalse(bucketCache.fullyCachedFiles.containsKey(path.getName()));
- }
-
- public void readStoreFile(Path storeFilePath, long offset) throws Exception {
+ public void readStoreFile(Path storeFilePath) throws Exception {
// Open the file
HFile.Reader reader = HFile.createReader(fs, storeFilePath, cacheConf,
true, conf);
-
while (!reader.prefetchComplete()) {
// Sleep for a bit
Thread.sleep(1000);
}
- HFileBlock block = reader.readBlock(offset, -1, false, true, false, true,
null, null);
- BlockCacheKey blockCacheKey = new BlockCacheKey(reader.getName(), offset);
- BucketEntry be = bucketCache.backingMap.get(blockCacheKey);
- boolean isCached = bucketCache.getBlock(blockCacheKey, true, false, true)
!= null;
-
- if (
- block.getBlockType() == BlockType.DATA || block.getBlockType() ==
BlockType.ROOT_INDEX
- || block.getBlockType() == BlockType.INTERMEDIATE_INDEX
- ) {
- assertTrue(isCached);
- }
}
public Path writeStoreFile(String fname) throws IOException {
