Check clustermeta

elastic · Jan 4, 2023 · 2549538 · 2549538
1 parent 2364212
commit 2549538
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/metricbeat/module/kubernetes/util/kubernetes.go b/metricbeat/module/kubernetes/util/kubernetes.go
@@ -589,13 +589,13 @@ func AddClusterECSMeta(base mb.BaseMetricSet) mapstr.M {
 	client, err := kubernetes.GetKubernetesClient(config.KubeConfig, config.KubeClientOptions)
 	if err != nil {
 		logp.Err("fail to get kubernetes client: %s", err)
-		return nil
+		return mapstr.M{}
 	}
 	cfg, _ := conf.NewConfigFrom(&config)
 	ecsClusterMeta, err := GetClusterECSMeta(cfg, client, base.Logger())
 	if err != nil {
 		logp.Info("could not retrieve cluster metadata: %s", err)
-		return nil
+		return mapstr.M{}
 	}
 	return ecsClusterMeta
 }