diff options
author | Patrick Wendell <pwendell@gmail.com> | 2013-07-29 13:17:23 -0700 |
---|---|---|
committer | Patrick Wendell <pwendell@gmail.com> | 2013-08-01 15:25:52 -0700 |
commit | 12d9c82c9b2a5040a2d1e5ab23ab44b41cbe1807 (patch) | |
tree | 6d3223a1bc017e4b71b77d7ebd75c6e8bbed506f /core | |
parent | 37bc64a20535215bd4638a928431ebd0e45f3a1a (diff) | |
download | spark-12d9c82c9b2a5040a2d1e5ab23ab44b41cbe1807.tar.gz spark-12d9c82c9b2a5040a2d1e5ab23ab44b41cbe1807.tar.bz2 spark-12d9c82c9b2a5040a2d1e5ab23ab44b41cbe1807.zip |
Small style fix
Diffstat (limited to 'core')
-rw-r--r-- | core/src/main/scala/spark/metrics/MetricsSystem.scala | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/metrics/MetricsSystem.scala b/core/src/main/scala/spark/metrics/MetricsSystem.scala index 5c98f892e1..1dacafa135 100644 --- a/core/src/main/scala/spark/metrics/MetricsSystem.scala +++ b/core/src/main/scala/spark/metrics/MetricsSystem.scala @@ -17,7 +17,7 @@ package spark.metrics -import com.codahale.metrics._ +import com.codahale.metrics.{Metric, MetricFilter, MetricRegistry} import java.util.Properties import java.util.concurrent.TimeUnit @@ -95,7 +95,6 @@ private[spark] class MetricsSystem private (val instance: String) extends Loggin def removeSource(source: Source) { sources -= source - println("Removing source: " + source.sourceName) registry.removeMatching(new MetricFilter { def matches(name: String, metric: Metric): Boolean = name.startsWith(source.sourceName) }) |