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

log

Browse Source
This commit is contained in:
vdimir 2024-10-25 11:10:33 +00:00
parent 349af95cd1
commit 084f878fb1
No known key found for this signature in database
GPG Key ID: 6EE4CE2BEDC51862
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/Interpreters/Aggregator.cpp
View File

@ -1504,6 +1504,7 @@ bool Aggregator::executeOnBlock(Columns columns,
&& worth_convert_to_two_level)
{
size_t size = current_memory_usage + params.min_free_disk_space;
LOG_DEBUG(&Poco::Logger::get("XXXX"), "{}:{}: {} {}", __FILE__, __LINE__, current_memory_usage, params.min_free_disk_space);
writeToTemporaryFile(result, size);
}
@ -1520,6 +1521,7 @@ void Aggregator::writeToTemporaryFile(AggregatedDataVariants & data_variants, si
size_t rows = data_variants.size();
std::unique_lock lk(tmp_files_mutex);
LOG_DEBUG(&Poco::Logger::get("XXXX"), "{}:{}: max_temp_file_size {}", __FILE__, __LINE__, max_temp_file_size);
auto & out_stream = tmp_files.emplace_back(getHeader(false), tmp_data.get(), max_temp_file_size);
lk.unlock();
@ -2932,6 +2934,7 @@ bool Aggregator::mergeOnBlock(Block block, AggregatedDataVariants & result, bool
&& worth_convert_to_two_level)
{
size_t size = current_memory_usage + params.min_free_disk_space;
LOG_DEBUG(&Poco::Logger::get("XXXX"), "{}:{}: {} {}", __FILE__, __LINE__, current_memory_usage, params.min_free_disk_space);
writeToTemporaryFile(result, size);
}