Reset elementsRead

markhamstra · Nov 18, 2014 · 486fc49 · 486fc49
1 parent e4f5695
commit 486fc49
Showing 1 changed file with 1 addition and 0 deletions.
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
   }
 
   /**