diff --git a/src/stream/src/task/stream_manager.rs b/src/stream/src/task/stream_manager.rs index d452decdce507..a628b3a841d7b 100644 --- a/src/stream/src/task/stream_manager.rs +++ b/src/stream/src/task/stream_manager.rs @@ -577,7 +577,7 @@ impl StreamActorManager { &actor, self.env.total_mem_usage(), self.streaming_metrics.clone(), - self.env.config().unique_user_stream_errors, + actor.dispatcher.len(), ); let vnode_bitmap = actor.vnode_bitmap.as_ref().map(|b| b.into()); let expr_context = actor.expr_context.clone().unwrap();