diff --git a/consensus/src/experimental/buffer_manager.rs b/consensus/src/experimental/buffer_manager.rs index 0076f1d9150c3..b4935b44d42bc 100644 --- a/consensus/src/experimental/buffer_manager.rs +++ b/consensus/src/experimental/buffer_manager.rs @@ -588,7 +588,7 @@ impl BufferManager { // We'll try to re-initiate the broadcast after 30s. Some((start_time, _)) => { start_time.elapsed() - < Duration::from_millis(COMMIT_VOTE_REBROADCAST_INTERVAL_MS) + >= Duration::from_millis(COMMIT_VOTE_REBROADCAST_INTERVAL_MS) }, }; if re_broadcast {