[beats] reduce log noise (#34460)

elastic · Feb 8, 2023 · 83422d5 · 83422d5
1 parent 78c035e
commit 83422d5
Showing 1 changed file with 13 additions and 2 deletions.
diff --git a/metricbeat/module/beat/stats/stats.go b/metricbeat/module/beat/stats/stats.go
@@ -18,7 +18,9 @@
 package stats
 
 import (
-	"github.com/pkg/errors"
+	"errors"
+	"fmt"
+	"time"
 
 	"github.com/elastic/beats/v7/metricbeat/mb"
 	"github.com/elastic/beats/v7/metricbeat/mb/parse"
@@ -45,6 +47,7 @@ var (
 // MetricSet defines all fields of the MetricSet
 type MetricSet struct {
 	*beat.MetricSet
+	lastClusterUUIDMessageTimestamp time.Time
 }
 
 // New create a new instance of the MetricSet
@@ -70,6 +73,14 @@ func (m *MetricSet) Fetch(r mb.ReporterV2) error {
 
 	clusterUUID, err := m.getClusterUUID()
 	if err != nil {
+		if errors.Is(err, beat.ErrClusterUUID) {
+			if time.Since(m.lastClusterUUIDMessageTimestamp) > 5*time.Minute {
+				m.lastClusterUUIDMessageTimestamp = time.Now()
+				m.Logger().Debug(err)
+			}
+			return nil
+		}
+
 		return err
 	}
 
@@ -79,7 +90,7 @@ func (m *MetricSet) Fetch(r mb.ReporterV2) error {
 func (m *MetricSet) getClusterUUID() (string, error) {
 	state, err := beat.GetState(m.MetricSet)
 	if err != nil {
-		return "", errors.Wrap(err, "could not get state information")
+		return "", fmt.Errorf("could not get state information: %w", err)
 	}
 
 	clusterUUID := state.Monitoring.ClusterUUID