Fix more test failures

apache · Aug 6, 2014 · b2a62ed · b2a62ed
1 parent 8be6218
commit b2a62ed
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/core/src/main/scala/org/apache/spark/util/collection/ExternalAppendOnlyMap.scala b/core/src/main/scala/org/apache/spark/util/collection/ExternalAppendOnlyMap.scala
@@ -205,6 +205,7 @@ class ExternalAppendOnlyMap[K, V, C](
 
         if (objectsWritten == serializerBatchSize) {
           flush()
+          curWriteMetrics = new ShuffleWriteMetrics()
           writer = blockManager.getDiskWriter(blockId, file, serializer, fileBufferSize,
             curWriteMetrics)
         }