Skip to content

Commit 9d889d6

Browse files
committed
undo some unnecessary changes
1 parent f48a7b0 commit 9d889d6

File tree

1 file changed

+2
-6
lines changed

1 file changed

+2
-6
lines changed

core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@ import java.io.{BufferedInputStream, FileNotFoundException, IOException, InputSt
2121
import java.util.concurrent.{ExecutorService, Executors, TimeUnit}
2222

2323
import scala.collection.mutable
24-
import scala.concurrent.duration.Duration
2524

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

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

46-
import org.apache.spark.deploy.history.FsHistoryProvider._
44+
import FsHistoryProvider._
4745

4846
private val NOT_STARTED = "<Not Started>"
4947

@@ -136,9 +134,7 @@ private[history] class FsHistoryProvider(conf: SparkConf) extends ApplicationHis
136134
}
137135
}
138136

139-
override def getListing(): Iterable[FsApplicationHistoryInfo] = {
140-
applications.values
141-
}
137+
override def getListing(): Iterable[FsApplicationHistoryInfo] = applications.values
142138

143139
override def getAppUI(appId: String): Option[SparkUI] = {
144140
try {

0 commit comments

Comments
 (0)