Skip to content

Commit d8ffb71

Browse files
Add file exists check
1 parent 2834c30 commit d8ffb71

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

core/src/main/scala/org/apache/spark/storage/DiskBlockManager.scala

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,9 @@ private[spark] class DiskBlockManager(conf: SparkConf, deleteFilesOnStop: Boolea
7070
old
7171
} else {
7272
val newDir = new File(localDirs(dirId), "%02x".format(subDirId))
73-
Files.createDirectory(newDir.toPath)
73+
if (!newDir.exists()) {
74+
Files.createDirectory(newDir.toPath)
75+
}
7476
subDirs(dirId)(subDirId) = newDir
7577
newDir
7678
}

0 commit comments

Comments
 (0)