From afaaef6875c28ad438c1ce37daea80e0ed2cb017 Mon Sep 17 00:00:00 2001 From: Jianfei Hu Date: Mon, 17 Jul 2023 16:15:28 +0000 Subject: [PATCH] wip checking whether system.merge cause sigsev. Signed-off-by: Jianfei Hu --- src/Storages/MergeTree/MergeList.cpp | 14 ++++++-------- 1 file changed, 6 insertions(+), 8 deletions(-) diff --git a/src/Storages/MergeTree/MergeList.cpp b/src/Storages/MergeTree/MergeList.cpp index a52704a9fb3..6a6ad7719b1 100644 --- a/src/Storages/MergeTree/MergeList.cpp +++ b/src/Storages/MergeTree/MergeList.cpp @@ -1,19 +1,16 @@ +#include #include #include -#include +#include #include #include #include -#include namespace DB { -MergeListElement::MergeListElement( - const StorageID & table_id_, - FutureMergedMutatedPartPtr future_part, - const ContextPtr & context) +MergeListElement::MergeListElement(const StorageID & table_id_, FutureMergedMutatedPartPtr future_part, const ContextPtr & context) : table_id{table_id_} , partition_id{future_part->part_info.partition_id} , result_part_name{future_part->name} @@ -40,8 +37,9 @@ MergeListElement::MergeListElement( source_data_version = future_part->parts[0]->info.getDataVersion(); is_mutation = (result_part_info.getDataVersion() != source_data_version); - WriteBufferFromString out(partition); - future_part->getPartition().serializeText(future_part->parts[0]->storage, out, {}); + partition = "jianfei-debugging-sigsev"; + // WriteBufferFromString out(partition); + // future_part->getPartition().serializeText(future_part->parts[0]->storage, out, {}); } thread_group = ThreadGroup::createForBackgroundProcess(context);