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

Fix tests

Browse Source
This commit is contained in:
kssenii 2023-01-17 16:41:44 +01:00
parent 4556b516d7
commit 9bb283f050
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/Interpreters/Cache/FileCache.cpp
View File

@ -92,12 +92,16 @@ void FileCache::initialize()
{
std::lock_guard lock(init_mutex);
if (is_initialized)
return;
try
{
loadMetadata();
}
catch (...)
{
tryLogCurrentException(__PRETTY_FUNCTION__);
init_exception = std::current_exception();
throw;
}
@ -1246,12 +1250,13 @@ std::vector<String> FileCache::tryGetCachePaths(const Key & key)
{
assertInitialized();
std::lock_guard lock(files_mutex);
auto key_transaction = createKeyTransaction(key, KeyNotFoundPolicy::RETURN_NULL);
if (!key_transaction)
return {};
const auto & cells_by_offset = *files[key];
std::vector<String> cache_paths;
for (const auto & [offset, cell] : cells_by_offset)
for (const auto & [offset, cell] : key_transaction->getOffsets())
{
if (cell.file_segment->state() == FileSegment::State::DOWNLOADED)
cache_paths.push_back(getPathInLocalCache(key, offset, cell.file_segment->getKind()));