diff --git a/internal/metrics/sparkapplication_metrics.go b/internal/metrics/sparkapplication_metrics.go index ac84a18f21..93ecfb53f3 100644 --- a/internal/metrics/sparkapplication_metrics.go +++ b/internal/metrics/sparkapplication_metrics.go @@ -368,7 +368,7 @@ func (m *SparkApplicationMetrics) getMetricLabels(app *v1beta2.SparkApplication) // Convert spark application validLabels to valid metric validLabels. validLabels := make(map[string]string) for key, val := range app.Labels { - newKey := util.CreateValidMetricNameLabel(m.prefix, key) + newKey := util.CreateValidMetricNameLabel("", key) validLabels[newKey] = val } diff --git a/internal/metrics/sparkpod_metrics.go b/internal/metrics/sparkpod_metrics.go index 3b57572546..43ca3e7d78 100644 --- a/internal/metrics/sparkpod_metrics.go +++ b/internal/metrics/sparkpod_metrics.go @@ -44,7 +44,7 @@ func NewSparkExecutorMetrics(prefix string, labels []string) *SparkExecutorMetri return &SparkExecutorMetrics{ prefix: prefix, - labels: labels, + labels: validLabels, runningCount: prometheus.NewGaugeVec( prometheus.GaugeOpts{