From 72333a3f023d92773047d17537eb36808e57797a Mon Sep 17 00:00:00 2001 From: Chen Chao Date: Tue, 15 Apr 2014 14:32:15 +0800 Subject: [PATCH] remove unnecessary brace --- .../scala/org/apache/spark/storage/BlockManager.scala | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/core/src/main/scala/org/apache/spark/storage/BlockManager.scala b/core/src/main/scala/org/apache/spark/storage/BlockManager.scala index b435e4e7127d3..f15fa4dd7ffd5 100644 --- a/core/src/main/scala/org/apache/spark/storage/BlockManager.scala +++ b/core/src/main/scala/org/apache/spark/storage/BlockManager.scala @@ -658,10 +658,9 @@ private[spark] class BlockManager( memoryStore.putValues(blockId, iterator, level, true) case ArrayBufferValues(array) => memoryStore.putValues(blockId, array, level, true) - case ByteBufferValues(bytes) => { + case ByteBufferValues(bytes) => bytes.rewind() memoryStore.putBytes(blockId, bytes, level) - } } size = res.size res.data match { @@ -677,10 +676,9 @@ private[spark] class BlockManager( tachyonStore.putValues(blockId, iterator, level, false) case ArrayBufferValues(array) => tachyonStore.putValues(blockId, array, level, false) - case ByteBufferValues(bytes) => { + case ByteBufferValues(bytes) => bytes.rewind() tachyonStore.putBytes(blockId, bytes, level) - } } size = res.size res.data match { @@ -697,10 +695,9 @@ private[spark] class BlockManager( diskStore.putValues(blockId, iterator, level, askForBytes) case ArrayBufferValues(array) => diskStore.putValues(blockId, array, level, askForBytes) - case ByteBufferValues(bytes) => { + case ByteBufferValues(bytes) => bytes.rewind() diskStore.putBytes(blockId, bytes, level) - } } size = res.size res.data match {