diff --git a/service/storage_service.cc b/service/storage_service.cc index fbca3a6109..4308568bbc 100644 --- a/service/storage_service.cc +++ b/service/storage_service.cc @@ -3165,12 +3165,9 @@ future<> storage_service::do_update_pending_ranges() { future<> storage_service::update_pending_ranges() { return get_storage_service().invoke_on(0, [] (auto& ss){ - ss._update_jobs++; return ss._update_pending_ranges_action.trigger_later().then([&ss] { // calculate_pending_ranges will modify token_metadata, we need to repliate to other cores - return ss.replicate_to_all_cores().finally([&ss, ss0 = ss.shared_from_this()] { - ss._update_jobs--; - }); + return ss.replicate_to_all_cores().then([s = ss.shared_from_this()] { }); }); }); } diff --git a/service/storage_service.hh b/service/storage_service.hh index 57e1ad0a7e..a89c058c87 100644 --- a/service/storage_service.hh +++ b/service/storage_service.hh @@ -151,7 +151,6 @@ private: gms::gossiper& _gossiper; sharded& _auth_service; sharded& _cql_config; - int _update_jobs{0}; // Note that this is obviously only valid for the current shard. Users of // this facility should elect a shard to be the coordinator based on any // given objective criteria