Removed open time metrics added inadvertently

cenyuhai · Feb 12, 2015 · 94e4237 · 94e4237
1 parent ace156c
commit 94e4237
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/core/src/main/scala/org/apache/spark/shuffle/sort/SortShuffleWriter.scala b/core/src/main/scala/org/apache/spark/shuffle/sort/SortShuffleWriter.scala
@@ -63,9 +63,7 @@ private[spark] class SortShuffleWriter[K, V, C](
       sorter.insertAll(records)
     }
 
-    val fileOpenStartTime = System.nanoTime
     val outputFile = shuffleBlockManager.getDataFile(dep.shuffleId, mapId)
-    writeMetrics.incShuffleWriteTime(System.nanoTime - fileOpenStartTime)
     val blockId = shuffleBlockManager.consolidateId(dep.shuffleId, mapId)
     val partitionLengths = sorter.writePartitionedFile(blockId, context, outputFile)
     shuffleBlockManager.writeIndexFile(dep.shuffleId, mapId, partitionLengths)