diff options
| author | Shivaram Venkataraman <shivaram@eecs.berkeley.edu> | 2013-06-03 12:29:38 -0700 |
|---|---|---|
| committer | Shivaram Venkataraman <shivaram@eecs.berkeley.edu> | 2013-06-03 12:29:38 -0700 |
| commit | 96943a1cc054d7cf80eb8d3dfc7fb19ce48d3c0a (patch) | |
| tree | 48ca0cef9d6a43f55ba51d06324724c3fe298799 /core/src | |
| parent | cd347f547a9a9b7bdd0d3f4734ae5c13be54f75d (diff) | |
| download | spark-96943a1cc054d7cf80eb8d3dfc7fb19ce48d3c0a.tar.gz spark-96943a1cc054d7cf80eb8d3dfc7fb19ce48d3c0a.tar.bz2 spark-96943a1cc054d7cf80eb8d3dfc7fb19ce48d3c0a.zip | |
var to val
Diffstat (limited to 'core/src')
| -rw-r--r-- | core/src/main/scala/spark/storage/DiskStore.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/storage/DiskStore.scala b/core/src/main/scala/spark/storage/DiskStore.scala index e51d258a21..cd85fa1e9d 100644 --- a/core/src/main/scala/spark/storage/DiskStore.scala +++ b/core/src/main/scala/spark/storage/DiskStore.scala @@ -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 ? |