diff --git a/streaming/stream_session.cc b/streaming/stream_session.cc
index d1267db756..a90e232cc4 100644
--- a/streaming/stream_session.cc
+++ b/streaming/stream_session.cc
@@ -350,7 +350,6 @@ void stream_session::send_failed_complete_message() {
         sslog.debug("[Stream #{}] GOT COMPLETE_MESSAGE Reply from {}", plan_id, id.addr);
     }).handle_exception([session, id, plan_id] (auto ep) {
         sslog.warn("[Stream #{}] COMPLETE_MESSAGE for {} has failed: {}", plan_id, id.addr, ep);
-        session->on_error();
     });
 }