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

[Fix](core) Fix file system scan deleted file (#29266)

Browse Source
This commit is contained in:
abmdocrt
2023-12-29 09:07:59 +08:00
committed by GitHub
parent c3679a2750
commit 2f29dda5aa
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
be/src/io/fs/local_file_system.cpp
View File

@ -32,6 +32,7 @@
#include <system_error>
#include <utility>
#include "common/exception.h"
#include "gutil/macros.h"
#include "io/fs/err_utils.h"
#include "io/fs/file_system.h"
@ -182,7 +183,11 @@ Status LocalFileSystem::directory_size(const Path& dir_path, size_t* dir_size) {
if (std::filesystem::exists(dir_path) && std::filesystem::is_directory(dir_path)) {
for (const auto& entry : std::filesystem::recursive_directory_iterator(dir_path)) {
if (std::filesystem::is_regular_file(entry)) {
*dir_size += std::filesystem::file_size(entry);
try {
*dir_size += std::filesystem::file_size(entry);
} catch (const std::exception& e) {
LOG(INFO) << "{}", e.what();
}
}
}
return Status::OK();