diff --git a/service/storage_service.cc b/service/storage_service.cc index 2050efed9373..1546d3a1986b 100644 --- a/service/storage_service.cc +++ b/service/storage_service.cc @@ -2293,6 +2293,7 @@ void storage_service::run_replace_ops(std::unordered_set& bootstrap_token sync_nodes.push_back(node); } } + wait_for_normal_state_handled_on_boot(sync_nodes, "replace", uuid).get(); sync_nodes.push_front(get_broadcast_address()); auto sync_nodes_generations = _gossiper.get_generation_for_nodes(sync_nodes).get(); // Map existing nodes to replacing nodes