From 486fc49e96b30120c0587018914971cdf4a94b72 Mon Sep 17 00:00:00 2001 From: Andrew Or Date: Mon, 17 Nov 2014 16:30:26 -0800 Subject: [PATCH] Reset `elementsRead` --- .../scala/org/apache/spark/util/collection/ExternalSorter.scala | 1 + 1 file changed, 1 insertion(+) 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 index 3136306a3adb0..97ddd96c98268 100644 --- 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 } /**