big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HDFS-17339:Skip cacheReport when one blockPool does not have CacheBlock on this DataNode (#6456). Contributed by lei w.

Browse Source 
Signed-off-by: Shuyan Zhang <zhangshuyan@apache.org>
This commit is contained in:
Lei313 2024-01-25 21:15:20 +08:00 committed by GitHub
parent 7272a3d960
commit ac471d7daa
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BPServiceActor.java
View File

@ -503,6 +503,10 @@ DatanodeCommand cacheReport() throws IOException {
String bpid = bpos.getBlockPoolId(); String bpid = bpos.getBlockPoolId();
List<Long> blockIds = dn.getFSDataset().getCacheReport(bpid); List<Long> blockIds = dn.getFSDataset().getCacheReport(bpid);
// Skip cache report
if (blockIds.isEmpty()) {
return null;
}
long createTime = monotonicNow(); long createTime = monotonicNow();
cmd = bpNamenode.cacheReport(bpRegistration, bpid, blockIds); cmd = bpNamenode.cacheReport(bpRegistration, bpid, blockIds);