thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-19 16:20:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix after merge

Browse Source
This commit is contained in:
Kirill Nikiforov 2024-04-26 15:22:34 +03:00
parent 0b5d8ee6fb
commit 115d7cfa57
No known key found for this signature in database
1 changed files with 2 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/Storages/StorageReplicatedMergeTree.cpp
View File

@ -7982,13 +7982,6 @@ void StorageReplicatedMergeTree::replacePartitionFrom(
ProfileEventsScope profile_events_scope;
MergeTreeData & src_data = checkStructureAndGetMergeTreeData(source_table, source_metadata_snapshot, metadata_snapshot);
String partition_id = getPartitionIDFromQuery(partition, query_context);
/// NOTE: Some covered parts may be missing in src_all_parts if corresponding log entries are not executed yet.
DataPartsVector src_all_parts = src_data.getVisibleDataPartsVectorInPartition(query_context, partition_id);
LOG_DEBUG(log, "Cloning {} parts", src_all_parts.size());
static const String TMP_PREFIX = "tmp_replace_from_";
auto zookeeper = getZooKeeper();
@ -7999,7 +7992,7 @@ void StorageReplicatedMergeTree::replacePartitionFrom(
throw DB::Exception(ErrorCodes::SUPPORT_IS_DISABLED, "Only support DROP/DETACH/ATTACH PARTITION ALL currently");
partitions = src_data.getAllPartitionIds();
LOG_INFO(log, "Will try to attach {} partitions", partitions.size());
LOG_INFO(log, "Will try to attach {} partitions without replace", partitions.size());
} else
{
partitions = std::unordered_set<String>();
@ -8008,6 +8001,7 @@ void StorageReplicatedMergeTree::replacePartitionFrom(
for (const auto & partition_id : partitions)
{
/// NOTE: Some covered parts may be missing in src_all_parts if corresponding log entries are not executed yet.
auto src_all_parts = src_data.getVisibleDataPartsVectorInPartition(query_context, partition_id);
LOG_DEBUG(log, "Cloning {} parts from partition '{}'", src_all_parts.size(), partition_id);