fix: pass correct param (#16078)

risingwavelabs · Apr 2, 2024 · bc4f766 · bc4f766
1 parent 2704525
commit bc4f766
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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();