We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c8031f6 commit b5b25ffCopy full SHA for b5b25ff
pkg/controller/controller.go
@@ -249,7 +249,7 @@ type Controller struct {
249
func Run(ctx context.Context, config *Configuration) {
250
utilruntime.Must(kubeovnv1.AddToScheme(scheme.Scheme))
251
klog.V(4).Info("Creating event broadcaster")
252
- eventBroadcaster := record.NewBroadcaster()
+ eventBroadcaster := record.NewBroadcasterWithCorrelatorOptions(record.CorrelatorOptions{BurstSize: 100})
253
eventBroadcaster.StartLogging(klog.Infof)
254
eventBroadcaster.StartRecordingToSink(&typedcorev1.EventSinkImpl{Interface: config.KubeFactoryClient.CoreV1().Events("")})
255
recorder := eventBroadcaster.NewRecorder(scheme.Scheme, corev1.EventSource{Component: controllerAgentName})
0 commit comments