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

Update StorageReplicatedMergeTree.cpp

Browse Source
This commit is contained in:
Alexander Tokmakov 2023-12-27 20:27:15 +01:00 committed by GitHub
parent 617ee5abaf
commit a3cba8e06f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/Storages/StorageReplicatedMergeTree.cpp
View File

@ -1835,9 +1835,13 @@ MergeTreeData::DataPartsVector StorageReplicatedMergeTree::checkPartChecksumsAnd
return {}; return {};
} }
size_t retries_count = 0;
constexpr size_t MAX_RETRIES_ON_SHUTDOWN = 3;
while (true) while (true)
{ {
if (shutdown_called || partial_shutdown_called) /// It still makes sense to make a few attempts on shutdown because we already did some job to create a part
/// and also we want to reduce the probability of issues with unexpected parts on restart
if (++retries_count > MAX_RETRIES_ON_SHUTDOWN && (shutdown_called || partial_shutdown_called))
throw Exception(ErrorCodes::ABORTED, "Cannot commit part because shutdown called"); throw Exception(ErrorCodes::ABORTED, "Cannot commit part because shutdown called");
Coordination::Requests ops; Coordination::Requests ops;