Skip to content
Closed
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -26,14 +26,15 @@ import com.google.common.io.Files
import org.scalatest.{BeforeAndAfterEach, FunSuite}

import org.apache.spark.SparkConf
import java.nio.file.Files
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I don't think this import is required (and it's causing a compile error anyway).


class DiskBlockManagerSuite extends FunSuite with BeforeAndAfterEach {
private val testConf = new SparkConf(false)
val rootDir0 = Files.createTempDir()
rootDir0.deleteOnExit()
val rootDir1 = Files.createTempDir()
rootDir1.deleteOnExit()
val rootDirs = rootDir0.getName + "," + rootDir1.getName
val rootDirs = rootDir0.getCanonicalPath + "," + rootDir1.getCanonicalPath
println("Created root dirs: " + rootDirs)

// This suite focuses primarily on consolidation features,
Expand Down