File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed
core/src/test/scala/org/apache/spark/shuffle/unsafe Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change 1717
1818package org .apache .spark .shuffle .unsafe
1919
20+ import java .io .File
21+
2022import scala .collection .JavaConverters ._
2123
2224import org .apache .commons .io .FileUtils
@@ -51,7 +53,7 @@ class UnsafeShuffleSuite extends ShuffleSuite with BeforeAndAfterAll {
5153 .setSerializer(new KryoSerializer (myConf))
5254 val shuffleDep = shuffledRdd.dependencies.head.asInstanceOf [ShuffleDependency [_, _, _]]
5355 assert(UnsafeShuffleManager .canUseUnsafeShuffle(shuffleDep))
54- def getAllFiles =
56+ def getAllFiles : Set [ File ] =
5557 FileUtils .listFiles(tmpDir, TrueFileFilter .INSTANCE , TrueFileFilter .INSTANCE ).asScala.toSet
5658 val filesBeforeShuffle = getAllFiles
5759 // Force the shuffle to be performed
@@ -82,7 +84,7 @@ class UnsafeShuffleSuite extends ShuffleSuite with BeforeAndAfterAll {
8284 .setSerializer(new JavaSerializer (myConf))
8385 val shuffleDep = shuffledRdd.dependencies.head.asInstanceOf [ShuffleDependency [_, _, _]]
8486 assert(! UnsafeShuffleManager .canUseUnsafeShuffle(shuffleDep))
85- def getAllFiles =
87+ def getAllFiles : Set [ File ] =
8688 FileUtils .listFiles(tmpDir, TrueFileFilter .INSTANCE , TrueFileFilter .INSTANCE ).asScala.toSet
8789 val filesBeforeShuffle = getAllFiles
8890 // Force the shuffle to be performed
You can’t perform that action at this time.
0 commit comments