diff options
| author | Charles Reiss <charles@eecs.berkeley.edu> | 2013-03-19 15:08:22 -0700 |
|---|---|---|
| committer | Charles Reiss <charles@eecs.berkeley.edu> | 2013-05-01 23:19:10 -0700 |
| commit | c847dd3da29483fede326cb9821b0d33f735137e (patch) | |
| tree | 3a550f309ebd6854fdc52cfde193a50f15f97e08 /core | |
| parent | aa8fe1a20923d4f86f04398d2cf70de14b04ab50 (diff) | |
| download | spark-c847dd3da29483fede326cb9821b0d33f735137e.tar.gz spark-c847dd3da29483fede326cb9821b0d33f735137e.tar.bz2 spark-c847dd3da29483fede326cb9821b0d33f735137e.zip | |
Don't accept generated temp directory names that can't be created successfully.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/storage/DiskStore.scala | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/storage/DiskStore.scala b/core/src/main/scala/spark/storage/DiskStore.scala index c9553d2e0f..215c25132b 100644 --- a/core/src/main/scala/spark/storage/DiskStore.scala +++ b/core/src/main/scala/spark/storage/DiskStore.scala @@ -168,8 +168,7 @@ private class DiskStore(blockManager: BlockManager, rootDirs: String) localDirId = "%s-%04x".format(dateFormat.format(new Date), rand.nextInt(65536)) localDir = new File(rootDir, "spark-local-" + localDirId) if (!localDir.exists) { - localDir.mkdirs() - foundLocalDir = true + foundLocalDir = localDir.mkdirs() } } catch { case e: Exception => |