aboutsummaryrefslogtreecommitdiff
path: root/core/src/main/scala/org/apache/spark/ui/SparkUI.scala
diff options
context:
space:
mode:
Diffstat (limited to 'core/src/main/scala/org/apache/spark/ui/SparkUI.scala')
-rw-r--r--core/src/main/scala/org/apache/spark/ui/SparkUI.scala16
1 files changed, 2 insertions, 14 deletions
diff --git a/core/src/main/scala/org/apache/spark/ui/SparkUI.scala b/core/src/main/scala/org/apache/spark/ui/SparkUI.scala
index 8da6884a38..4608bce202 100644
--- a/core/src/main/scala/org/apache/spark/ui/SparkUI.scala
+++ b/core/src/main/scala/org/apache/spark/ui/SparkUI.scala
@@ -17,13 +17,10 @@
package org.apache.spark.ui
-import java.util.{Date, ServiceLoader}
-
-import scala.collection.JavaConverters._
+import java.util.Date
import org.apache.spark.status.api.v1.{ApiRootResource, ApplicationAttemptInfo, ApplicationInfo,
UIRoot}
-import org.apache.spark.util.Utils
import org.apache.spark.{Logging, SecurityManager, SparkConf, SparkContext}
import org.apache.spark.scheduler._
import org.apache.spark.storage.StorageStatusListener
@@ -157,16 +154,7 @@ private[spark] object SparkUI {
appName: String,
basePath: String,
startTime: Long): SparkUI = {
- val sparkUI = create(
- None, conf, listenerBus, securityManager, appName, basePath, startTime = startTime)
-
- val listenerFactories = ServiceLoader.load(classOf[SparkHistoryListenerFactory],
- Utils.getContextOrSparkClassLoader).asScala
- listenerFactories.foreach { listenerFactory =>
- val listeners = listenerFactory.createListeners(conf, sparkUI)
- listeners.foreach(listenerBus.addListener)
- }
- sparkUI
+ create(None, conf, listenerBus, securityManager, appName, basePath, startTime = startTime)
}
/**