diff --git a/src/runtime/communication.rs b/src/runtime/communication.rs
index cbda5c50e76d2932dfa6c187ce5aafa48f2a84d1..83e5ede6e7378bc849393b85fe82ca92a76cf8cf 100644
--- a/src/runtime/communication.rs
+++ b/src/runtime/communication.rs
@@ -364,8 +364,7 @@ impl Connector {
         // restore the invariant: !native_batches.is_empty()
         comm.native_batches.push(Default::default());
 
-        comm.endpoint_manager
-            .udp_endpoints_round_start(&mut *cu.inner.logger, &mut rctx.spec_var_stream);
+        comm.endpoint_manager.udp_endpoints_round_start(&mut *cu.inner.logger);
         // Call to another big method; keep running this round until a distributed decision is reached
         let decision = Self::sync_reach_decision(
             cu,