From 4776f9e40fcd2bd61025031f0b3c680c29cd81a1 Mon Sep 17 00:00:00 2001 From: Kousuke Saruta Date: Thu, 18 Sep 2014 04:12:04 +0900 Subject: [PATCH] Modified MetricsSystemSuite.scala --- .../scala/org/apache/spark/metrics/MetricsSystemSuite.scala | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/core/src/test/scala/org/apache/spark/metrics/MetricsSystemSuite.scala b/core/src/test/scala/org/apache/spark/metrics/MetricsSystemSuite.scala index 96a5a1231813e..b2de9abf731e8 100644 --- 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