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

Suppress gdb warning

Browse Source
This commit is contained in:
alesapin 2020-12-17 13:25:31 +03:00
parent b74e7accf1
commit 911a1cd48f
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/Storages/MergeTree/MergeTreeDataPartWriterCompact.cpp
View File

@ -143,16 +143,15 @@ void MergeTreeDataPartWriterCompact::write(const Block & block, const IColumn::P
header = result_block.cloneEmpty();
columns_buffer.add(result_block.mutateColumns());
size_t current_mark = getCurrentMark();
size_t current_mark_rows = index_granularity.getMarkRows(current_mark);
size_t current_mark_rows = index_granularity.getMarkRows(getCurrentMark());
size_t rows_in_buffer = columns_buffer.size();
if (rows_in_buffer >= current_mark_rows)
{
Block flushed_block = header.cloneWithColumns(columns_buffer.releaseColumns());
auto granules_to_write = getGranulesToWrite(index_granularity, flushed_block.rows(), current_mark, /* last_block = */ false);
auto granules_to_write = getGranulesToWrite(index_granularity, flushed_block.rows(), getCurrentMark(), /* last_block = */ false);
writeDataBlockPrimaryIndexAndSkipIndices(flushed_block, granules_to_write);
setCurrentMark(current_mark + granules_to_write.size());
setCurrentMark(getCurrentMark() + granules_to_write.size());
}
}