Skip to content

Commit 12598e1

Browse files
gaborgsomogyisrowen
authored andcommitted
[MINOR] FsHistoryProvider import cleanup
### What changes were proposed in this pull request? As it has been discussed in #26397 (comment) `FsHistoryProvider` import section has to be cleaned up. ### Why are the changes needed? Unused imports. ### Does this PR introduce any user-facing change? No. ### How was this patch tested? Existing unit tests. Closes #26436 from gaborgsomogyi/SPARK-29755. Authored-by: Gabor Somogyi <gabor.g.somogyi@gmail.com> Signed-off-by: Sean Owen <sean.owen@databricks.com>
1 parent 1e408d6 commit 12598e1

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)