diff --git a/core/src/main/scala/org/apache/spark/storage/memory/MemoryStore.scala b/core/src/main/scala/org/apache/spark/storage/memory/MemoryStore.scala index 1fe649dfbe15d173a1c3a1b03257b1cefb0c05b4..ef75d639331b8f1deb66d5695063f45bb7135d55 100644 --- a/core/src/main/scala/org/apache/spark/storage/memory/MemoryStore.scala +++ b/core/src/main/scala/org/apache/spark/storage/memory/MemoryStore.scala @@ -95,7 +95,7 @@ private[spark] class MemoryStore( def compare(other: OurBlockIdAndSizeType): Int = this.size.compare(other.size) } - private val blockIdAndSizeSet = new SortedSet[OurBlockIdAndSizeType]() + private val blockIdAndSizeSet = SortedSet[OurBlockIdAndSizeType]() private val entries = new LinkedHashMap[BlockId, MemoryEntry[_]](32, 0.75f, true) // A mapping from taskAttemptId to amount of memory used for unrolling a block (in bytes)