Reset elementsRead

Andrew Or · Andrew Or · commit 486fc49e96b3 · 2014-11-17T16:30:26.000-08:00
diff --git a/core/src/main/scala/org/apache/spark/util/collection/ExternalSorter.scala b/core/src/main/scala/org/apache/spark/util/collection/ExternalSorter.scala
@@ -288,6 +288,7 @@ private[spark] class ExternalSorter[K, V, C](
     myMemoryThreshold = 0
 
     _memoryBytesSpilled += memorySize
+    elementsRead = 0
   }
 
   /**

Original file line number	Diff line number	Diff line change
`@@ -288,6 +288,7 @@ private[spark] class ExternalSorter[K, V, C](`
`288`	`288`	`myMemoryThreshold = 0`
`289`	`289`
`290`	`290`	`_memoryBytesSpilled += memorySize`
	`291`	`+ elementsRead = 0`
`291`	`292`	`}`
`292`	`293`
`293`	`294`	`/**`