Skip to content

Commit d2b8ccd

Browse files
committed
small fix
1 parent 6e2e29b commit d2b8ccd

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

core/src/main/scala/org/apache/spark/storage/memory/MemoryStore.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -411,8 +411,8 @@ private[spark] class MemoryStore(
411411
entry
412412
}
413413

414-
putIterator(blockId, values, classTag, MemoryMode.OFF_HEAP,
415-
storeValue, estimateSize, createMemoryEntry) match {
414+
putIterator(blockId, values, classTag, memoryMode, storeValue,
415+
estimateSize, createMemoryEntry) match {
416416
case Right(storedSize) => Right(storedSize)
417417
case Left(unrollMemoryUsedByThisBlock) =>
418418
// We ran out of space while unrolling the values for this block

0 commit comments

Comments
 (0)