diff --git a/service/storage_service.cc b/service/storage_service.cc index 1d92458d3b..52d29f1bf3 100644 --- a/service/storage_service.cc +++ b/service/storage_service.cc @@ -1272,7 +1272,7 @@ public: " for the response from the topology coordinator"); if (utils::get_local_injector().enter("pre_server_start_drop_expiring")) { - _ss._group0->modifiable_address_map().force_drop_expiring_entries(); + _ss._gossiper.get_mutable_address_map().force_drop_expiring_entries(); } _ss._join_node_request_done.set_value(); @@ -6842,7 +6842,7 @@ future storage_service::join_node_response_handler(jo } if (utils::get_local_injector().enter("join_node_response_drop_expiring")) { - _group0->modifiable_address_map().force_drop_expiring_entries(); + _gossiper.get_mutable_address_map().force_drop_expiring_entries(); } try { diff --git a/service/topology_coordinator.cc b/service/topology_coordinator.cc index e9b882d4ce..3dd2aa753b 100644 --- a/service/topology_coordinator.cc +++ b/service/topology_coordinator.cc @@ -2226,7 +2226,7 @@ class topology_coordinator : public endpoint_lifecycle_subscriber { auto validation_result = validate_joining_node(node); if (utils::get_local_injector().enter("handle_node_transition_drop_expiring")) { - _group0.modifiable_address_map().force_drop_expiring_entries(); + _gossiper.get_mutable_address_map().force_drop_expiring_entries(); } // When the validation succeeded, it's important that all nodes in the