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

Remove exception

Browse Source
This commit is contained in:
alesapin 2019-03-26 12:46:09 +03:00
parent bfbe1263ac
commit 2dfd6779f6
2 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dbms/src/Storages/MergeTree/MergeTreeDataMergerMutator.cpp
View File

@ -768,7 +768,7 @@ MergeTreeData::MutableDataPartPtr MergeTreeDataMergerMutator::mergePartsToTempor
rows_sources_read_buf.seek(0, 0); rows_sources_read_buf.seek(0, 0);
ColumnGathererStream column_gathered_stream(column_name, column_part_streams, rows_sources_read_buf); ColumnGathererStream column_gathered_stream(column_name, column_part_streams, rows_sources_read_buf);
std::cerr << "TOINDEXGRANULARITY EMPTY:" << to.getIndexGranularity().getMarksCount() << std::endl; std::cerr << "TOINDEXGRANULARITY MARKS COUNT:" << to.getIndexGranularity().getMarksCount() << std::endl;
MergedColumnOnlyOutputStream column_to( MergedColumnOnlyOutputStream column_to(
data, data,
column_gathered_stream.getHeader(), column_gathered_stream.getHeader(),

3
dbms/src/Storages/MergeTree/MergedBlockOutputStream.cpp
View File

@ -556,6 +556,7 @@ void MergedBlockOutputStream::writeImpl(const Block & block, const IColumn::Perm
{ {
block.checkNumberOfRows(); block.checkNumberOfRows();
size_t rows = block.rows(); size_t rows = block.rows();
std::cerr << "BLOCK ROWS:" << rows << std::endl;
if (!rows) if (!rows)
return; return;
@ -775,8 +776,6 @@ MergedColumnOnlyOutputStream::MergedColumnOnlyOutputStream(
header(header_), part_path(part_path_), sync(sync_), skip_offsets(skip_offsets_), header(header_), part_path(part_path_), sync(sync_), skip_offsets(skip_offsets_),
already_written_offset_columns(already_written_offset_columns) already_written_offset_columns(already_written_offset_columns)
{ {
if (index_granularity.empty())
throw Exception("Can't write column without information about part index granularity", ErrorCodes::LOGICAL_ERROR);
} }
void MergedColumnOnlyOutputStream::write(const Block & block) void MergedColumnOnlyOutputStream::write(const Block & block)