thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-21 23:21:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

log

Browse Source
This commit is contained in:
vdimir 2024-10-16 11:57:11 +00:00
parent d10b79020e
commit db2aab199d
No known key found for this signature in database
GPG Key ID: 6EE4CE2BEDC51862
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/Interpreters/TemporaryDataOnDisk.cpp
View File

@ -58,6 +58,7 @@ public:
explicit TemporaryFileInLocalCache(FileCache & file_cache, size_t max_file_size = 0)
{
const auto key = FileSegment::Key::random();
LOG_TRACE(getLogger("TemporaryFileOnLocalDisk"), "Creating temporary file in cache with key {}", key);
segment_holder = file_cache.set(
key, 0, std::max(10_MiB, max_file_size),
CreateFileSegmentSettings(FileSegmentKind::Ephemeral), FileCache::getCommonUser());
@ -91,6 +92,7 @@ public:
explicit TemporaryFileOnLocalDisk(VolumePtr volume, size_t max_file_size = 0)
: path_to_file("tmp" + toString(UUIDHelpers::generateV4()))
{
LOG_TRACE(getLogger("TemporaryFileOnLocalDisk"), "Creating temporary file '{}'", path_to_file);
if (max_file_size > 0)
{
auto reservation = volume->reserve(max_file_size);
@ -129,9 +131,14 @@ public:
try
{
if (disk->exists(path_to_file))
{
LOG_TRACE(getLogger("TemporaryFileOnLocalDisk"), "Removing temporary file '{}'", path_to_file);
disk->removeRecursive(path_to_file);
}
else
{
LOG_WARNING(getLogger("TemporaryFileOnLocalDisk"), "Temporary path '{}' does not exist in '{}' on disk {}", path_to_file, disk->getPath(), disk->getName());
}
}
catch (...)
{