diff --git a/dht/range_streamer.cc b/dht/range_streamer.cc
index 186e9e33fc..a8bc5dd734 100644
--- a/dht/range_streamer.cc
+++ b/dht/range_streamer.cc
@@ -251,25 +251,6 @@ future<> range_streamer::add_ranges(const sstring& keyspace_name, dht::token_ran
 }
 
 future<> range_streamer::stream_async() {
-    return seastar::async([this] {
-        int sleep_time = 60;
-        for (;;) {
-            try {
-                do_stream_async().get();
-                break;
-            } catch (...) {
-                logger.warn("{} failed to stream. Will retry in {} seconds ...", _description, sleep_time);
-                sleep_abortable(std::chrono::seconds(sleep_time), _abort_source).get();
-                sleep_time *= 1.5;
-                if (++_nr_retried >= _nr_max_retry) {
-                    throw;
-                }
-            }
-        }
-    });
-}
-
-future<> range_streamer::do_stream_async() {
     auto nr_ranges_remaining = nr_ranges_to_stream();
     logger.info("{} starts, nr_ranges_remaining={}", _description, nr_ranges_remaining);
     auto start = lowres_clock::now();
diff --git a/dht/range_streamer.hh b/dht/range_streamer.hh
index f43ba9a050..2f6679a7a8 100644
--- a/dht/range_streamer.hh
+++ b/dht/range_streamer.hh
@@ -142,7 +142,6 @@ private:
     }
 public:
     future<> stream_async();
-    future<> do_stream_async();
     size_t nr_ranges_to_stream();
 private:
     distributed<replica::database>& _db;
@@ -155,9 +154,6 @@ private:
     streaming::stream_reason _reason;
     std::unordered_multimap<sstring, std::unordered_map<inet_address, dht::token_range_vector>> _to_stream;
     std::unordered_set<std::unique_ptr<i_source_filter>> _source_filters;
-    // Retry the stream plan _nr_max_retry times
-    unsigned _nr_retried = 0;
-    unsigned _nr_max_retry = 5;
     // Number of tx and rx ranges added
     unsigned _nr_tx_added = 0;
     unsigned _nr_rx_added = 0;