Don't accept generated temp directory names that can't be created successfully.

2013-03-19 15:08:22 -07:00 · 2013-03-19 15:08:22 -07:00 · c847dd3da2
parent aa8fe1a209
commit c847dd3da2
1 changed files with 1 additions and 2 deletions
--- 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 =>