diff --git a/dbms/src/Storages/StorageReplicatedMergeTree.cpp b/dbms/src/Storages/StorageReplicatedMergeTree.cpp index 59723999643..d6b66e2a577 100644 --- a/dbms/src/Storages/StorageReplicatedMergeTree.cpp +++ b/dbms/src/Storages/StorageReplicatedMergeTree.cpp @@ -1978,7 +1978,7 @@ void StorageReplicatedMergeTree::becomeLeader() if (merge_selecting_thread.joinable()) { LOG_INFO(log, "Deleting old leader"); - is_leader_node = false; // exit trigger inside thread + is_leader_node = false; /// exit trigger inside thread merge_selecting_thread.join(); }