diff --git a/spark-operator/src/main/java/org/apache/spark/k8s/operator/metrics/source/OperatorJosdkMetrics.java b/spark-operator/src/main/java/org/apache/spark/k8s/operator/metrics/source/OperatorJosdkMetrics.java index 86a34ff5..eee97a4c 100644 --- a/spark-operator/src/main/java/org/apache/spark/k8s/operator/metrics/source/OperatorJosdkMetrics.java +++ b/spark-operator/src/main/java/org/apache/spark/k8s/operator/metrics/source/OperatorJosdkMetrics.java @@ -44,6 +44,7 @@ import org.apache.spark.k8s.operator.BaseResource; import org.apache.spark.k8s.operator.SparkApplication; +import org.apache.spark.k8s.operator.SparkCluster; import org.apache.spark.metrics.source.Source; import org.apache.spark.util.Clock; import org.apache.spark.util.SystemClock; @@ -305,6 +306,8 @@ private Counter getCounter(Class klass, String... names) { if (resourceGvk.getKind().equals(SparkApplication.class.getSimpleName())) { resourceClass = SparkApplication.class; + } else if (resourceGvk.getKind().equals(SparkCluster.class.getSimpleName())) { + resourceClass = SparkCluster.class; } else { return Optional.empty(); }