Github user srowen commented on a diff in the pull request:
https://github.com/apache/spark/pull/19358#discussion_r141268693
--- Diff:
resource-managers/mesos/src/main/scala/org/apache/spark/scheduler/cluster/mesos/MesosClusterSchedulerSource.scala
---
@@ -23,8 +23,10 @@ import org.apache.spark.metrics.source.Source
private[mesos] class MesosClusterSchedulerSource(scheduler:
MesosClusterScheduler)
extends Source {
+ private val registry = new MetricRegistry()
+
override def sourceName: String = "mesos_cluster"
- override def metricRegistry: MetricRegistry = new MetricRegistry()
+ override def metricRegistry: MetricRegistry = registry
--- End diff --
Actually, just change both of these to `override val ...`
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
