diff options
author | Shivaram Venkataraman <shivaram@eecs.berkeley.edu> | 2013-05-29 17:29:34 -0700 |
---|---|---|
committer | Shivaram Venkataraman <shivaram@eecs.berkeley.edu> | 2013-05-29 17:29:34 -0700 |
commit | 19fd6d54c012bd9f73620e9b817f4975de162277 (patch) | |
tree | b3ea1c788cfcd884d724556a9bd771c179f40430 | |
parent | b79b10a6d60a7f1f199e6bddd1243a05c57526ad (diff) | |
download | spark-19fd6d54c012bd9f73620e9b817f4975de162277.tar.gz spark-19fd6d54c012bd9f73620e9b817f4975de162277.tar.bz2 spark-19fd6d54c012bd9f73620e9b817f4975de162277.zip |
Also flush serializer in revertPartialWrites
-rw-r--r-- | core/src/main/scala/spark/storage/DiskStore.scala | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/core/src/main/scala/spark/storage/DiskStore.scala b/core/src/main/scala/spark/storage/DiskStore.scala index 1829c2f92e..c7281200e7 100644 --- a/core/src/main/scala/spark/storage/DiskStore.scala +++ b/core/src/main/scala/spark/storage/DiskStore.scala @@ -70,6 +70,7 @@ private class DiskStore(blockManager: BlockManager, rootDirs: String) override def revertPartialWrites() { // Discard current writes. We do this by flushing the outstanding writes and // truncate the file to the last valid position. + objOut.flush() bs.flush() channel.truncate(lastValidPosition) } |