diff --git a/rust-arroyo/src/processing/strategies/reduce.rs b/rust-arroyo/src/processing/strategies/reduce.rs index 1ce00125..e50a672c 100644 --- a/rust-arroyo/src/processing/strategies/reduce.rs +++ b/rust-arroyo/src/processing/strategies/reduce.rs @@ -177,8 +177,7 @@ impl Reduce { return Ok(()); } - // FIXME: this used to be in seconds - timer!("arroyo.strategies.reduce.batch_time", batch_time); + timer!("arroyo.strategies.reduce.batch_time.ms", batch_time); let batch_state = mem::replace( &mut self.batch_state,