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

Speed up mutations for non-replicated MergeTree a bit

Browse Source
This commit is contained in:
Alexey Milovidov 2024-07-23 04:09:06 +02:00
parent bd9bfc34a9
commit 4cbb8bab56
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/Storages/StorageMergeTree.cpp
View File

@ -506,13 +506,14 @@ Int64 StorageMergeTree::startMutation(const MutationCommands & commands, Context
}
Int64 version;
String mutation_id;
{
std::lock_guard lock(currently_processing_in_background_mutex);
MergeTreeMutationEntry entry(commands, disk, relative_data_path, insert_increment.get(), current_tid, getContext()->getWriteSettings());
version = increment.get();
entry.commit(version);
String mutation_id = entry.file_name;
mutation_id = entry.file_name;
if (txn)
txn->addMutation(shared_from_this(), mutation_id);
@ -527,9 +528,9 @@ Int64 StorageMergeTree::startMutation(const MutationCommands & commands, Context
}
throw Exception(ErrorCodes::LOGICAL_ERROR, "Mutation {} already exists, it's a bug", version);
}
LOG_INFO(log, "Added mutation: {}{}", mutation_id, additional_info);
}
LOG_INFO(log, "Added mutation: {}{}", mutation_id, additional_info);
background_operations_assignee.trigger();
return version;
}