mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-09-20 16:50:48 +00:00
One more fix for PVS-Studio
This commit is contained in:
parent
bba2641bd0
commit
19059ef650
@ -392,7 +392,7 @@ void MergedBlockOutputStream::writeImpl(const Block & block, const IColumn::Perm
|
|||||||
auto & stream = *skip_indices_streams[i];
|
auto & stream = *skip_indices_streams[i];
|
||||||
size_t prev_pos = 0;
|
size_t prev_pos = 0;
|
||||||
|
|
||||||
size_t current_mark = 0;
|
size_t skip_index_current_mark = 0;
|
||||||
while (prev_pos < rows)
|
while (prev_pos < rows)
|
||||||
{
|
{
|
||||||
UInt64 limit = 0;
|
UInt64 limit = 0;
|
||||||
@ -402,7 +402,7 @@ void MergedBlockOutputStream::writeImpl(const Block & block, const IColumn::Perm
|
|||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
limit = index_granularity.getMarkRows(current_mark);
|
limit = index_granularity.getMarkRows(skip_index_current_mark);
|
||||||
if (skip_indices_aggregators[i]->empty())
|
if (skip_indices_aggregators[i]->empty())
|
||||||
{
|
{
|
||||||
skip_indices_aggregators[i] = index->createIndexAggregator();
|
skip_indices_aggregators[i] = index->createIndexAggregator();
|
||||||
@ -435,7 +435,7 @@ void MergedBlockOutputStream::writeImpl(const Block & block, const IColumn::Perm
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
prev_pos = pos;
|
prev_pos = pos;
|
||||||
current_mark++;
|
++skip_index_current_mark;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user