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

Some debug

Browse Source
This commit is contained in:
alesapin 2018-12-03 11:52:21 +03:00
parent 5524b77915
commit 3efb00b0ef
3 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
dbms/src/Storages/MergeTree/MergeTreeData.cpp
View File

@ -2227,11 +2227,6 @@ MergeTreeData::DataPartsVector MergeTreeData::getDataPartsVector(const DataPartS
(*out_states)[i] = res[i]->state; (*out_states)[i] = res[i]->state;
} }
} }
std::cerr << "NOT INITIALIZED DATA PART\n";
for (auto part : res) {
std::cerr << "FullPath:" << part->getFullPath() << std::endl;
std::cerr << "MarkSFileExtensSion:" << part->marks_file_extension << std::endl;
}
return res; return res;
} }

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

@ -273,6 +273,8 @@ void MergeTreeReader::Stream::loadMarks()
size_t file_size = Poco::File(path).getSize(); size_t file_size = Poco::File(path).getSize();
size_t expected_file_size = one_mark_bytes_size * marks_count; size_t expected_file_size = one_mark_bytes_size * marks_count;
std::cerr << "Marks size in bytes:" << one_mark_bytes_size << std::endl;
std::cerr << "Makrs count:" << marks_count << std::endl;
if (expected_file_size != file_size) if (expected_file_size != file_size)
throw Exception( throw Exception(
"bad size of marks file `" + path + "':" + std::to_string(file_size) + ", must be: " + std::to_string(expected_file_size), "bad size of marks file `" + path + "':" + std::to_string(file_size) + ", must be: " + std::to_string(expected_file_size),

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

@ -39,12 +39,14 @@ IMergedBlockOutputStream::IMergedBlockOutputStream(
, max_compress_block_size(max_compress_block_size_) , max_compress_block_size(max_compress_block_size_)
, aio_threshold(aio_threshold_) , aio_threshold(aio_threshold_)
, compression_settings(compression_settings_) , compression_settings(compression_settings_)
, index_granularity(index_granularity_)
, marks_file_extension(storage.index_granularity_bytes == 0 ? FIXED_MARKS_FILE_EXTENSION : ADAPTIVE_MARKS_FILE_EXTENSION) , marks_file_extension(storage.index_granularity_bytes == 0 ? FIXED_MARKS_FILE_EXTENSION : ADAPTIVE_MARKS_FILE_EXTENSION)
, mark_size_in_bytes(storage.index_granularity_bytes == 0 ? FIXED_MARK_BYTE_SIZE : ADAPTIVE_MARK_BYTE_SIZE) , mark_size_in_bytes(storage.index_granularity_bytes == 0 ? FIXED_MARK_BYTE_SIZE : ADAPTIVE_MARK_BYTE_SIZE)
, blocks_are_granules_size(blocks_are_granules_size_) , blocks_are_granules_size(blocks_are_granules_size_)
, index_granularity(index_granularity_)
, compute_granularity(index_granularity.empty()) , compute_granularity(index_granularity.empty())
{ {
if (blocks_are_granules_size && !index_granularity.empty())
throw Exception("Can't take information about index granularity from blocks, when non empty index_granularity specified", ErrorCodes::LOGICAL_ERROR);
} }