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

ignore instead append

Browse Source
This commit is contained in:
Vladislav Smirnov 2019-03-13 14:18:18 +03:00
parent 7d822d8081
commit a916b62f33
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dbms/src/Formats/CapnProtoRowInputStream.cpp
View File

@ -310,13 +310,13 @@ bool CapnProtoRowInputStream::read(MutableColumns & columns, RowReadExtension &)
if (heap_array.size() == 0) if (heap_array.size() == 0)
{ {
auto parsed = (msg.getEnd() - base) * sizeof(capnp::word); auto parsed = (msg.getEnd() - base) * sizeof(capnp::word);
istr.position() += parsed; istr.ignore(parsed);
} }
// Advance buffer position if used with remaining bytes from previous buffer // Advance buffer position if used with remaining bytes from previous buffer
else if (remainingBytes != 0) else if (remainingBytes != 0)
{ {
auto parsed = (msg.getEnd() - heap_array.begin()) * sizeof(capnp::word) - remainingBytes; auto parsed = (msg.getEnd() - heap_array.begin()) * sizeof(capnp::word) - remainingBytes;
istr.position() += parsed; istr.ignore(parsed);
} }
return true; return true;