diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-09-28 19:02:41 -0700 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-09-28 19:02:41 -0700 |
| commit | 815d6bd69a0c1ba0e94fc0785f5c3619b37f19c5 (patch) | |
| tree | e4834e6e34176f10ce64dc9eaba89427aa1de44d /core/src/main | |
| parent | e54e1d70434e9be32ae1f5e91808b2fd173b761e (diff) | |
| download | spark-815d6bd69a0c1ba0e94fc0785f5c3619b37f19c5.tar.gz spark-815d6bd69a0c1ba0e94fc0785f5c3619b37f19c5.tar.bz2 spark-815d6bd69a0c1ba0e94fc0785f5c3619b37f19c5.zip | |
Renamed subdirs option
Diffstat (limited to 'core/src/main')
| -rw-r--r-- | core/src/main/scala/spark/storage/DiskStore.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/storage/DiskStore.scala b/core/src/main/scala/spark/storage/DiskStore.scala index e912bc985b..e46cbdff16 100644 --- a/core/src/main/scala/spark/storage/DiskStore.scala +++ b/core/src/main/scala/spark/storage/DiskStore.scala @@ -14,7 +14,7 @@ class DiskStore(blockManager: BlockManager, rootDirs: String) extends BlockStore(blockManager) { val MAX_DIR_CREATION_ATTEMPTS: Int = 10 - val subDirsPerLocalDir = System.getProperty("spark.diskStore.subdirs", "64").toInt + val subDirsPerLocalDir = System.getProperty("spark.diskStore.subDirectories", "64").toInt // Create one local directory for each path mentioned in spark.local.dir; then, inside this // directory, create multiple subdirectories that we will hash files into, in order to avoid |