From 5d98ce3de1deeeb7fbdc26b9303a591c46f1892b Mon Sep 17 00:00:00 2001
From: Reynold Xin <rxin@apache.org>
Date: Tue, 30 Sep 2014 00:56:32 -0700
Subject: [PATCH] Flip buffer.

---
 .../scala/org/apache/spark/network/BlockTransferService.scala    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/core/src/main/scala/org/apache/spark/network/BlockTransferService.scala b/core/src/main/scala/org/apache/spark/network/BlockTransferService.scala
index 2a0a1a0bc0a14..d3ed683c7e880 100644
--- a/core/src/main/scala/org/apache/spark/network/BlockTransferService.scala
+++ b/core/src/main/scala/org/apache/spark/network/BlockTransferService.scala
@@ -94,6 +94,7 @@ abstract class BlockTransferService extends Closeable {
         lock.synchronized {
           val ret = ByteBuffer.allocate(data.size.toInt)
           ret.put(data.nioByteBuffer())
+          ret.flip()
           result = Left(new NioManagedBuffer(ret))
           lock.notify()
         }