Fix more test failures

sryza · sryza · commit b2a62ed37840 · 2014-08-06T09:09:22.000-07:00
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)
         }

Original file line number	Diff line number	Diff line change
`@@ -205,6 +205,7 @@ class ExternalAppendOnlyMap[K, V, C](`
`205`	`205`
`206`	`206`	`if (objectsWritten == serializerBatchSize) {`
`207`	`207`	`flush()`
	`208`	`+ curWriteMetrics = new ShuffleWriteMetrics()`
`208`	`209`	`writer = blockManager.getDiskWriter(blockId, file, serializer, fileBufferSize,`
`209`	`210`	`curWriteMetrics)`
`210`	`211`	`}`