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

dbms: removed bad code [#METR-17988].

Browse Source
This commit is contained in:
Alexey Milovidov 2015-09-16 08:09:58 +03:00
parent 200742d632
commit fa0e61086f
2 changed files with 0 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
dbms/include/DB/Storages/MergeTree/ReplicatedMergeTreeBlockOutputStream.h
View File

@ -201,13 +201,10 @@ public:
/// Если данные отличались от тех, что были вставлены ранее с тем же ID, бросим исключение.
expected_checksums.checkEqual(part->checksums, true);
/// У part-а уменьшится refcount, и его смогут удалить сразу при откате транзакции, а не позже.
part.reset();
transaction.rollback();
}
else if (zookeeper->exists(quorum_status_path))
{
part.reset();
transaction.rollback();
throw Exception("Another quorum insert has been already started", ErrorCodes::UNSATISFIED_QUORUM_FOR_PREVIOUS_WRITE);

11
dbms/src/Storages/MergeTree/MergeTreeData.cpp
View File

@ -799,17 +799,6 @@ void MergeTreeData::replaceParts(const DataPartsVector & remove, const DataParts
part->remove_time = clear_without_timeout ? 0 : time(0);
removePartContributionToColumnSizes(part);
data_parts.erase(part);
/// use_count равен двум, если part-ом владеет только remove и all_data_parts.
if (clear_without_timeout && part.use_count() <= 2)
{
LOG_DEBUG(log, "Removing part " << part->name);
part->remove();
Poco::ScopedLock<Poco::FastMutex> lock_all(all_data_parts_mutex);
all_data_parts.erase(part);
}
/// Иначе кусок будет удалён с диска позже.
}
for (const DataPartPtr & part : add)