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

Fix

Browse Source
This commit is contained in:
kssenii 2024-11-12 16:58:30 +01:00
parent 847f0441e3
commit 844594de18
1 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -646,8 +646,6 @@ void FileSegment::shrinkFileSegmentToDownloadedSize(const LockedKey & locked_key
}
size_t aligned_downloaded_size = FileCacheUtils::roundUpToMultiple(downloaded_size, cache->getBoundaryAlignment());
aligned_downloaded_size = std::min(aligned_downloaded_size, range().size());
chassert(aligned_downloaded_size >= downloaded_size);
if (aligned_downloaded_size == range().size())
@ -655,13 +653,18 @@ void FileSegment::shrinkFileSegmentToDownloadedSize(const LockedKey & locked_key
/// Nothing to resize;
return;
}
if (downloaded_size == aligned_downloaded_size)
else if (aligned_downloaded_size > range().size()
|| downloaded_size == aligned_downloaded_size)
{
/// Does not make sense to resize upwords.
setDownloadState(State::DOWNLOADED, lock);
segment_range.right = segment_range.left + downloaded_size - 1;
}
else
{
setDownloadState(State::PARTIALLY_DOWNLOADED, lock);
segment_range.right = segment_range.left + aligned_downloaded_size - 1;
segment_range.right = segment_range.left + aligned_downloaded_size - 1;
}
const size_t diff = reserved_size - downloaded_size;
chassert(reserved_size >= downloaded_size);