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

Remove old parts immediately

Browse Source
This commit is contained in:
Alexey Milovidov 2024-10-18 18:28:28 +02:00
parent 0b74588a9e
commit 91a32c3511
1 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
utils/merge-visualizer/index.html
View File

@ -187,6 +187,7 @@ async function update(data) {
const matches = data.part_name.match(/[\w-]+_(\d+)_(\d+)_(\d+)(?:_(\d+))?/);
const min_block_id = +matches[1];
const max_block_id = +matches[2];
const level = +matches[3];
if (data.event_type == 'NewPart' || data.event_type == 'DownloadPart' || data.event_type == 'MergeParts' || data.event_type == 'MutatePart') {
@ -208,7 +209,9 @@ async function update(data) {
part = document.createElement('div');
part.id = part_id;
part['data-name'] = data.part_name;
part['data-min-block-id'] = min_block_id;
part['data-max-block-id'] = max_block_id;
part['data-level'] = level;
part.className = 'part';
part_title = document.createElement('div');
@ -224,9 +227,21 @@ async function update(data) {
let inserted = false;
for (const child of partition.childNodes) {
if (child['data-min-block-id'] >= min_block_id) {
const child_min_block_id = child['data-min-block-id'];
const child_max_block_id = child['data-max-block-id'];
const child_level = child['data-level'];
if (!inserted && child_min_block_id >= min_block_id) {
partition.insertBefore(part, child);
inserted = true;
}
/// Covered parts.
if (level > child_level && min_block_id <= child_min_block_id && max_block_id >= child_max_block_id) {
delete currently_active_parts[data.table_uuid][child['data-name']];
--num_parts;
partition.removeChild(child);
}
if (child_min_block_id > max_block_id) {
break;
}
}