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

Better logging in background move task.

Browse Source
This commit is contained in:
Vladimir Chebotarev 2019-12-13 00:34:57 +03:00
parent 386302ffbc
commit 9393bb0f12
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
dbms/src/Storages/MergeTree/MergeTreePartsMover.cpp
View File

@ -89,6 +89,10 @@ bool MergeTreePartsMover::selectPartsForMove(
const AllowedMovingPredicate & can_move,
const std::lock_guard<std::mutex> & /* moving_parts_lock */)
{
unsigned parts_to_move_by_policy_rules = 0;
unsigned parts_to_move_by_ttl_rules = 0;
double parts_to_move_total_size_bytes = 0.0;
MergeTreeData::DataPartsVector data_parts = data->getDataPartsVector();
if (data_parts.empty())
@ -143,6 +147,8 @@ bool MergeTreePartsMover::selectPartsForMove(
{
to_insert->second.decreaseRequiredSizeAndRemoveRedundantParts(part->bytes_on_disk);
}
++parts_to_move_by_ttl_rules;
parts_to_move_total_size_bytes += part->bytes_on_disk;
}
else
{
@ -165,9 +171,15 @@ bool MergeTreePartsMover::selectPartsForMove(
break;
}
parts_to_move.emplace_back(part, std::move(reservation));
++parts_to_move_by_policy_rules;
parts_to_move_total_size_bytes += part->bytes_on_disk;
}
}
LOG_TRACE(log, "Selected " << parts_to_move_by_policy_rules << " parts to move according to storage policy rules and "
<< parts_to_move_by_ttl_rules << " parts according to TTL rules, "
<< formatReadableSizeWithBinarySuffix(parts_to_move_total_size_bytes) << " total");
return !parts_to_move.empty();
}