diff --git a/src/stream/src/executor/merge.rs b/src/stream/src/executor/merge.rs index b09351223c00c..b58ea1f44c513 100644 --- a/src/stream/src/executor/merge.rs +++ b/src/stream/src/executor/merge.rs @@ -820,10 +820,7 @@ mod tests { ) }; - test_env.inject_barrier( - &exchange_client_test_barrier(), - [remote_input.actor_id()], - ); + test_env.inject_barrier(&exchange_client_test_barrier(), [remote_input.actor_id()]); pin_mut!(remote_input);