Skip to content

Commit ad09236

Browse files
committed
Flip buffer.
1 parent 0dae310 commit ad09236

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

core/src/main/scala/org/apache/spark/network/BlockTransferService.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -94,6 +94,7 @@ abstract class BlockTransferService extends Closeable {
9494
lock.synchronized {
9595
val ret = ByteBuffer.allocate(data.size.toInt)
9696
ret.put(data.nioByteBuffer())
97+
ret.flip()
9798
result = Left(new NioManagedBuffer(ret))
9899
lock.notify()
99100
}

0 commit comments

Comments
 (0)