Modified MetricsSystemSuite.scala

avulanov · Sep 17, 2014 · 4776f9e · 4776f9e
1 parent efcb6e1
commit 4776f9e
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/core/src/test/scala/org/apache/spark/metrics/MetricsSystemSuite.scala b/core/src/test/scala/org/apache/spark/metrics/MetricsSystemSuite.scala
@@ -34,6 +34,8 @@ class MetricsSystemSuite extends FunSuite with BeforeAndAfter {
 
   test("MetricsSystem with default config") {
     val metricsSystem = MetricsSystem.createMetricsSystem("default", conf, securityMgr)
+    metricsSystem.registerSources()
+    metricsSystem.registerSinks()
     val sources = metricsSystem.sources
     val sinks = metricsSystem.sinks
 
@@ -44,6 +46,8 @@ class MetricsSystemSuite extends FunSuite with BeforeAndAfter {
 
   test("MetricsSystem with sources add") {
     val metricsSystem = MetricsSystem.createMetricsSystem("test", conf, securityMgr)
+    metricsSystem.registerSources()
+    metricsSystem.registerSinks()
     val sources = metricsSystem.sources
     val sinks = metricsSystem.sinks