From eeb0f31da08e6bf609b8ca6cc6509b949dcbac6e Mon Sep 17 00:00:00 2001 From: Juliusz Sompolski Date: Wed, 6 Dec 2017 21:25:35 +0100 Subject: [PATCH] SPARK-22721 --- .../main/java/org/apache/spark/unsafe/map/BytesToBytesMap.java | 1 + 1 file changed, 1 insertion(+) diff --git a/core/src/main/java/org/apache/spark/unsafe/map/BytesToBytesMap.java b/core/src/main/java/org/apache/spark/unsafe/map/BytesToBytesMap.java index 4fadfe36cd716..7fdcf22c45f73 100644 --- a/core/src/main/java/org/apache/spark/unsafe/map/BytesToBytesMap.java +++ b/core/src/main/java/org/apache/spark/unsafe/map/BytesToBytesMap.java @@ -879,6 +879,7 @@ public LongArray getArray() { * Reset this map to initialized state. */ public void reset() { + updatePeakMemoryUsed(); numKeys = 0; numValues = 0; freeArray(longArray);