diff --git a/libbeat/autodiscover/providers/kubernetes/node.go b/libbeat/autodiscover/providers/kubernetes/node.go index a78622756cd6..95e23b33d2a5 100644 --- a/libbeat/autodiscover/providers/kubernetes/node.go +++ b/libbeat/autodiscover/providers/kubernetes/node.go @@ -105,7 +105,6 @@ func (n *node) OnUpdate(obj interface{}) { time.AfterFunc(n.config.CleanupTimeout, func() { n.emit(node, "stop") }) } else { n.logger.Debugf("Watcher Node update: %+v", obj) - // TODO: figure out how to avoid stop starting when node status is periodically being updated by kubelet n.emit(node, "stop") n.emit(node, "start") }