Skip to content
Snippets Groups Projects
Commit 6fe9d4e6 authored by Matei Zaharia's avatar Matei Zaharia
Browse files

Merge pull request #592 from woggling/localdir-fix

Don't accept generated local directory names that can't be created
parents 538ee755 c847dd3d
No related branches found
No related tags found
No related merge requests found
......@@ -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 =>
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment