Flip buffer.

apache · Oct 10, 2014 · 5d98ce3 · 5d98ce3
1 parent f6c220d
commit 5d98ce3
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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()
         }