Correct behavior when writing unopened file

aarondav · aarondav · commit 53b3f6d890ac · 2014-07-30T22:38:02.000-07:00
diff --git a/core/src/main/scala/org/apache/spark/storage/BlockObjectWriter.scala b/core/src/main/scala/org/apache/spark/storage/BlockObjectWriter.scala
@@ -154,8 +154,8 @@ private[spark] class DiskBlockObjectWriter(
       objOut.flush()
       bs.flush()
       close()
-      finalPosition = file.length()
     }
+    finalPosition = file.length()
   }
 
   // Discard current writes. We do this by flushing the outstanding writes and then

Original file line number	Diff line number	Diff line change
`@@ -154,8 +154,8 @@ private[spark] class DiskBlockObjectWriter(`
`154`	`154`	`objOut.flush()`
`155`	`155`	`bs.flush()`
`156`	`156`	`close()`
`157`		`- finalPosition = file.length()`
`158`	`157`	`}`
	`158`	`+ finalPosition = file.length()`
`159`	`159`	`}`
`160`	`160`
`161`	`161`	`// Discard current writes. We do this by flushing the outstanding writes and then`