Skip to content

Commit dd1c66d

Browse files
committed
when old is deleted, it will throw an exception where call it
1 parent 2a55bc2 commit dd1c66d

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ private[spark] class DiskBlockManager(blockManager: BlockManager, conf: SparkCon
6767
if (subDir == null) {
6868
subDir = subDirs(dirId).synchronized {
6969
val old = subDirs(dirId)(subDirId)
70-
if (old != null && old.exists()) {
70+
if (old != null) {
7171
old
7272
} else {
7373
val newDir = new File(localDirs(dirId), "%02x".format(subDirId))

0 commit comments

Comments
 (0)