diff --git a/src/runtime/communication.rs b/src/runtime/communication.rs index 3c966b92235b970a444b9a00114fc5f064d11435..b16e7a7537fcd8b0fd9498182f9064de078c02fc 100644 --- a/src/runtime/communication.rs +++ b/src/runtime/communication.rs @@ -352,8 +352,6 @@ 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); // Call to another big method; keep running this round until a distributed decision is reached let decision = Self::sync_reach_decision( cu,