From 9669aa522bd18e869c9a5133d8b8acedfc3d22c8 Mon Sep 17 00:00:00 2001 From: Saravanan Balasubramanian <33908564+sarabala1979@users.noreply.github.com> Date: Thu, 10 Dec 2020 12:03:24 -0800 Subject: [PATCH] fix(controller): Increate default EventSpamBurst in Eventrecorder (#4698) Signed-off-by: Saravanan Balasubramanian --- workflow/events/event_recorder_manager.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/workflow/events/event_recorder_manager.go b/workflow/events/event_recorder_manager.go index 5e6ed30c0805..3b26e1ed0efa 100644 --- a/workflow/events/event_recorder_manager.go +++ b/workflow/events/event_recorder_manager.go @@ -11,6 +11,9 @@ import ( "k8s.io/client-go/tools/record" ) +// by default, allow a source to send 10000 events about an object +const defaultSpamBurst = 10000 + type EventRecorderManager interface { Get(namespace string) record.EventRecorder } @@ -28,7 +31,8 @@ func (m *eventRecorderManager) Get(namespace string) record.EventRecorder { if ok { return eventRecorder } - eventBroadcaster := record.NewBroadcaster() + eventCorrelationOption := record.CorrelatorOptions{BurstSize: defaultSpamBurst} + eventBroadcaster := record.NewBroadcasterWithCorrelatorOptions(eventCorrelationOption) eventBroadcaster.StartLogging(log.Debugf) eventBroadcaster.StartRecordingToSink(&typedcorev1.EventSinkImpl{Interface: m.kubernetes.CoreV1().Events(namespace)}) m.eventRecorders[namespace] = eventBroadcaster.NewRecorder(scheme.Scheme, apiv1.EventSource{Component: "workflow-controller"})