diff --git a/service/topology_coordinator.cc b/service/topology_coordinator.cc index 3b360c0fba..7ad31ed768 100644 --- a/service/topology_coordinator.cc +++ b/service/topology_coordinator.cc @@ -2446,10 +2446,12 @@ future<> topology_coordinator::build_coordinator_state(group0_guard guard) { [this] (abort_source*) { return start_operation();}, _as); } + auto tmptr = get_token_metadata_ptr(); + auto sl_version = co_await _sys_ks.get_service_levels_version(); if (!sl_version || *sl_version < 2) { rtlogger.info("migrating service levels data"); - co_await qos::service_level_controller::migrate_to_v2(_gossiper.num_endpoints(), _sys_ks, _sys_ks.query_processor(), _group0.client(), _as); + co_await qos::service_level_controller::migrate_to_v2(tmptr->get_all_endpoints().size(), _sys_ks, _sys_ks.query_processor(), _group0.client(), _as); } rtlogger.info("building initial raft topology state and CDC generation"); @@ -2466,7 +2468,6 @@ future<> topology_coordinator::build_coordinator_state(group0_guard guard) { }; // Create a new CDC generation - auto tmptr = get_token_metadata_ptr(); auto get_sharding_info_for_host_id = [&] (locator::host_id host_id) -> std::pair { const auto ep = tmptr->get_endpoint_for_host_id_if_known(host_id); if (!ep) {