Add a comment and fix the code style

zsxwing · zsxwing · commit c431095b05a8 · 2014-09-17T09:56:42.000+08:00
diff --git a/core/src/main/scala/org/apache/spark/storage/DiskStore.scala b/core/src/main/scala/org/apache/spark/storage/DiskStore.scala
@@ -77,11 +77,12 @@ private[spark] class DiskStore(blockManager: BlockManager, diskManager: DiskBloc
       try {
         blockManager.dataSerializeStream(blockId, outputStream, values)
       } finally {
+        // Close outputStream here because it should be closed before file is deleted.
         outputStream.close()
       }
     } catch {
       case e: Throwable => {
-        if(file.exists()) {
+        if (file.exists()) {
           file.delete()
         }
         throw e

Original file line number	Diff line number	Diff line change
`@@ -77,11 +77,12 @@ private[spark] class DiskStore(blockManager: BlockManager, diskManager: DiskBloc`
`77`	`77`	`try {`
`78`	`78`	`blockManager.dataSerializeStream(blockId, outputStream, values)`
`79`	`79`	`} finally {`
	`80`	`+ // Close outputStream here because it should be closed before file is deleted.`
`80`	`81`	`outputStream.close()`
`81`	`82`	`}`
`82`	`83`	`} catch {`
`83`	`84`	`case e: Throwable => {`
`84`		`- if(file.exists()) {`
	`85`	`+ if (file.exists()) {`
`85`	`86`	`file.delete()`
`86`	`87`	`}`
`87`	`88`	`throw e`