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

Fix after merge

Browse Source
This commit is contained in:
Kseniia Sumarokova 2023-08-24 12:02:41 +02:00 committed by kssenii
parent a4f39fe134
commit b12881b5da
3 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Interpreters/Cache/FileSegment.cpp
View File

@ -776,6 +776,8 @@ bool FileSegment::assertCorrectnessUnlocked(const FileSegmentGuard::Lock &) cons
{
chassert(downloader_id.empty());
chassert(downloaded_size == reserved_size);
chassert(downloaded_size == range().size());
chassert(downloaded_size > 0);
chassert(std::filesystem::file_size(getPathInLocalCache()) > 0);
chassert(queue_iterator);
check_iterator(queue_iterator);

4
src/Interpreters/Cache/Metadata.cpp
View File

@ -898,7 +898,7 @@ FileSegments LockedKey::sync()
"File segment has unexpected state: DETACHED ({})", file_segment->getInfoForLog());
}
if (file_segment->getDownloadedSize(false) == 0)
if (file_segment->getDownloadedSize() == 0)
{
++it;
continue;
@ -918,7 +918,7 @@ FileSegments LockedKey::sync()
}
const size_t actual_size = fs::file_size(path);
const size_t expected_size = file_segment->getDownloadedSize(false);
const size_t expected_size = file_segment->getDownloadedSize();
if (actual_size == expected_size)
{

2
src/Interpreters/InterpreterSystemQuery.cpp
View File

@ -407,7 +407,7 @@ BlockIO InterpreterSystemQuery::execute()
const auto path = cache->getPathInLocalCache(file_segment->key(), file_segment->offset(), file_segment->getKind());
res_columns[i++]->insert(cache_name);
res_columns[i++]->insert(path);
res_columns[i++]->insert(file_segment->getDownloadedSize(false));
res_columns[i++]->insert(file_segment->getDownloadedSize());
}
};