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

fix logical-error when undoing quorum insert transaction

Browse Source
This commit is contained in:
Han Fei 2024-03-26 18:38:05 +01:00
parent 233a75505b
commit 97fca6682e
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/Storages/MergeTree/ReplicatedMergeTreeSink.cpp
View File

@ -940,14 +940,25 @@ std::pair<std::vector<String>, bool> ReplicatedMergeTreeSinkImpl<async_insert>::
});
bool node_exists = false;
bool quorum_fail_exists = false;
/// The loop will be executed at least once
new_retry_controller.retryLoop([&]
{
fiu_do_on(FailPoints::replicated_merge_tree_commit_zk_fail_when_recovering_from_hw_fault, { zookeeper->forceFailureBeforeOperation(); });
zookeeper->setKeeper(storage.getZooKeeper());
node_exists = zookeeper->exists(fs::path(storage.replica_path) / "parts" / part->name);
if (isQuorumEnabled())
quorum_fail_exists = zookeeper->exists(fs::path(storage.zookeeper_path) / "quorum" / "failed_parts" / part->name);
});
/// if it has quorum fail node, the restarting thread will clean the garbage.
if (quorum_fail_exists)
{
LOG_INFO(log, "Part {} fails to commit and will not retry or clean garbage. Restarting Thread will do everything.", part->name);
transaction.clear();
return CommitRetryContext::ERROR;
}
if (node_exists)
{
LOG_DEBUG(log, "Insert of part {} recovered from keeper successfully. It will be committed", part->name);