thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-13 02:53:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix

Browse Source
This commit is contained in:
kssenii 2022-10-07 12:26:54 +02:00
parent eb6e60753d
commit 53d54ae6c9
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/Disks/IO/ReadIndirectBufferFromRemoteFS.cpp
View File

@ -100,11 +100,11 @@ bool ReadIndirectBufferFromRemoteFS::nextImpl()
chassert(offset <= size);
chassert(size <= internal_buffer.size());
if (size)
{
file_offset_of_buffer_end = impl->getFileOffsetOfBufferEnd();
size_t bytes_read = size - offset;
if (bytes_read)
working_buffer = Buffer(internal_buffer.begin() + offset, internal_buffer.begin() + size);
}
file_offset_of_buffer_end = impl->getFileOffsetOfBufferEnd();
/// In case of multiple files for the same file in clickhouse (i.e. log family)
/// file_offset_of_buffer_end will not match getImplementationBufferOffset()
@ -112,7 +112,7 @@ bool ReadIndirectBufferFromRemoteFS::nextImpl()
chassert(file_offset_of_buffer_end >= impl->getImplementationBufferOffset());
chassert(file_offset_of_buffer_end <= impl->getFileSize());
return size;
return bytes_read;
}
}