fix(add_kubernetes_metadata): wait for init to complete during close (#47662)

kruskall · web-flow · commit c2fc36f80070 · 2025-11-22T15:07:44.000+01:00
* fix(add_kubernetes_metadata): wait for init to complete during close

prevent goroutine leak and wait for init to complete when
closing the processor

* Update kubernetes.go

* Update kubernetes.go
diff --git a/libbeat/processors/add_kubernetes_metadata/kubernetes.go b/libbeat/processors/add_kubernetes_metadata/kubernetes.go
@@ -376,6 +376,9 @@ func (k *kubernetesAnnotator) Run(event *beat.Event) (*beat.Event, error) {
 }
 
 func (k *kubernetesAnnotator) Close() error {
+	// ensure there are no goroutines leaking
+	// after the processor has been closed
+	k.initOnce.Do(func() {})
 	if k.watcher != nil {
 		k.watcher.Stop()
 	}

Original file line number	Diff line number	Diff line change
`@@ -376,6 +376,9 @@ func (k kubernetesAnnotator) Run(event beat.Event) (*beat.Event, error) {`
`376`	`376`	`}`
`377`	`377`
`378`	`378`	`func (k *kubernetesAnnotator) Close() error {`
	`379`	`+ // ensure there are no goroutines leaking`
	`380`	`+ // after the processor has been closed`
	`381`	`+ k.initOnce.Do(func() {})`
`379`	`382`	`if k.watcher != nil {`
`380`	`383`	`k.watcher.Stop()`
`381`	`384`	`}`