database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[chore](regression test) check disk is good (#29740)

Browse Source
This commit is contained in:
yujun
2024-01-11 20:40:08 +08:00
committed by yiguolei
parent 89995402dd
commit 0d6ab3c68c
2 changed files with 32 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
fe/fe-core/src/main/java/org/apache/doris/master/ReportHandler.java
View File

@ -563,9 +563,12 @@ public class ReportHandler extends Daemon {
LOG.warn("backend doesn't exist. id: " + backendId);
return;
}
List<String> badDisks = backendDisks.values().stream().filter(disk -> !disk.isUsed())
.map(disk -> "path=" + disk.getRootPath() + ", path hash=" + disk.getPathHash())
.collect(Collectors.toList());
backend.updateDisks(backendDisks);
LOG.info("finished to handle disk report from backend {}, cost: {} ms",
backendId, (System.currentTimeMillis() - start));
LOG.info("finished to handle disk report from backend: {}, disk size: {}, bad disk: {}, cost: {} ms",
backendId, backendDisks.size(), badDisks, (System.currentTimeMillis() - start));
}
private static void cpuReport(long backendId, int cpuCores, int pipelineExecutorSize) {