Skip to content

Commit c2fb430

Browse files
committed
Removing more un-needed array-buffer to iterator conversions
1 parent 627a8b7 commit c2fb430

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

core/src/main/scala/org/apache/spark/storage/BlockManager.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -360,7 +360,7 @@ private[spark] class BlockManager(
360360
// TODO: Consider creating a putValues that also takes in a iterator?
361361
val valuesBuffer = new ArrayBuffer[Any]
362362
valuesBuffer ++= values
363-
memoryStore.putValues(blockId, valuesBuffer.toIterator, level, true).data match {
363+
memoryStore.putValues(blockId, valuesBuffer, level, true).data match {
364364
case Left(values2) =>
365365
return Some(values2)
366366
case _ =>
@@ -703,7 +703,7 @@ private[spark] class BlockManager(
703703
logInfo("Writing block " + blockId + " to disk")
704704
data match {
705705
case Left(elements) =>
706-
diskStore.putValues(blockId, elements.toIterator, level, false)
706+
diskStore.putValues(blockId, elements, level, false)
707707
case Right(bytes) =>
708708
diskStore.putBytes(blockId, bytes, level)
709709
}

0 commit comments

Comments
 (0)