diff options
| -rw-r--r-- | core/src/main/scala/org/apache/spark/storage/DiskStore.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/org/apache/spark/storage/DiskStore.scala b/core/src/main/scala/org/apache/spark/storage/DiskStore.scala index e6d6190bc3..8a8dc8c1b5 100644 --- a/core/src/main/scala/org/apache/spark/storage/DiskStore.scala +++ b/core/src/main/scala/org/apache/spark/storage/DiskStore.scala @@ -88,11 +88,11 @@ private class DiskStore(blockManager: BlockManager, rootDirs: String) if (initialized) { if (syncWrites) { // Force outstanding writes to disk and track how long it takes - val start = System.nanoTime() objOut.flush() + val start = System.nanoTime() fos.getFD.sync() - objOut.close() _timeWriting += System.nanoTime() - start + objOut.close() } else { objOut.close() } |