Skip to content

Commit

Permalink
undo some unnecessary changes
Browse files Browse the repository at this point in the history
  • Loading branch information
squito committed Apr 28, 2015
1 parent f48a7b0 commit 9d889d6
Showing 1 changed file with 2 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,6 @@ import java.io.{BufferedInputStream, FileNotFoundException, IOException, InputSt
import java.util.concurrent.{ExecutorService, Executors, TimeUnit}

import scala.collection.mutable
import scala.concurrent.duration.Duration

import com.google.common.util.concurrent.{MoreExecutors, ThreadFactoryBuilder}
import org.apache.hadoop.fs.{FileStatus, Path}
Expand All @@ -33,7 +32,6 @@ import org.apache.spark.io.CompressionCodec
import org.apache.spark.scheduler._
import org.apache.spark.ui.SparkUI
import org.apache.spark.util.{ThreadUtils, Utils}
import org.apache.spark.{Logging, SecurityManager, SparkConf}

/**
* A class that provides application history from event logs stored in the file system.
Expand All @@ -43,7 +41,7 @@ import org.apache.spark.{Logging, SecurityManager, SparkConf}
private[history] class FsHistoryProvider(conf: SparkConf) extends ApplicationHistoryProvider
with Logging {

import org.apache.spark.deploy.history.FsHistoryProvider._
import FsHistoryProvider._

private val NOT_STARTED = "<Not Started>"

Expand Down Expand Up @@ -136,9 +134,7 @@ private[history] class FsHistoryProvider(conf: SparkConf) extends ApplicationHis
}
}

override def getListing(): Iterable[FsApplicationHistoryInfo] = {
applications.values
}
override def getListing(): Iterable[FsApplicationHistoryInfo] = applications.values

override def getAppUI(appId: String): Option[SparkUI] = {
try {
Expand Down

0 comments on commit 9d889d6

Please sign in to comment.