ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

var to val

Browse source
This commit is contained in:
Shivaram Venkataraman 2013-06-03 12:29:38 -07:00
parent cd347f547a
commit 96943a1cc0
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
core/src/main/scala/spark/storage/DiskStore.scala
View file

@ -195,7 +195,7 @@ private class DiskStore(blockManager: BlockManager, rootDirs: String)
}
private def createFile(blockId: String, allowAppendExisting: Boolean = false): File = {
var file = getFile(blockId)
val file = getFile(blockId)
if (!allowAppendExisting && file.exists()) {
// NOTE(shivaram): Delete the file if it exists. This might happen if a ShuffleMap task
// was rescheduled on the same machine as the old task ?