Skip to content

Commit e6a8364

Browse files
committed
[MINOR]FsHistoryProvider import cleanup
1 parent 7759f71 commit e6a8364

File tree

1 file changed

+2
-5
lines changed

1 file changed

+2
-5
lines changed

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

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -21,20 +21,18 @@ import java.io.{File, FileNotFoundException, IOException}
2121
import java.nio.file.Files
2222
import java.util.{Date, ServiceLoader}
2323
import java.util.concurrent.{ConcurrentHashMap, ExecutorService, Future, TimeUnit}
24-
import java.util.zip.{ZipEntry, ZipOutputStream}
24+
import java.util.zip.ZipOutputStream
2525

2626
import scala.collection.JavaConverters._
2727
import scala.collection.mutable
2828
import scala.concurrent.ExecutionException
2929
import scala.io.Source
30-
import scala.util.Try
3130
import scala.xml.Node
3231

3332
import com.fasterxml.jackson.annotation.JsonIgnore
34-
import com.google.common.io.ByteStreams
3533
import com.google.common.util.concurrent.MoreExecutors
3634
import org.apache.hadoop.fs.{FileStatus, FileSystem, Path}
37-
import org.apache.hadoop.hdfs.{DFSInputStream, DistributedFileSystem}
35+
import org.apache.hadoop.hdfs.DistributedFileSystem
3836
import org.apache.hadoop.hdfs.protocol.HdfsConstants
3937
import org.apache.hadoop.security.AccessControlException
4038
import org.fusesource.leveldbjni.internal.NativeDB
@@ -47,7 +45,6 @@ import org.apache.spark.internal.config.History._
4745
import org.apache.spark.internal.config.Status._
4846
import org.apache.spark.internal.config.Tests.IS_TESTING
4947
import org.apache.spark.internal.config.UI._
50-
import org.apache.spark.io.CompressionCodec
5148
import org.apache.spark.scheduler._
5249
import org.apache.spark.scheduler.ReplayListenerBus._
5350
import org.apache.spark.status._

0 commit comments

Comments
 (0)