diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2013-10-07 21:28:12 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2013-10-07 21:28:12 -0700 |
| commit | 9e9e9e1b42df26244d29b8920a41177e296a85c4 (patch) | |
| tree | ba57f524bfe66311c1c60b54d979c8094d3fdf50 | |
| parent | b08306c5cf015f6f2ca3b808cda127d438b80fc8 (diff) | |
| download | spark-9e9e9e1b42df26244d29b8920a41177e296a85c4.tar.gz spark-9e9e9e1b42df26244d29b8920a41177e296a85c4.tar.bz2 spark-9e9e9e1b42df26244d29b8920a41177e296a85c4.zip | |
Making the timing block more narrow for the sync
| -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() } |