-
- Downloads
[SPARK-17204][CORE] Fix replicated off heap storage
(Jira: https://issues.apache.org/jira/browse/SPARK-17204) ## What changes were proposed in this pull request? There are a couple of bugs in the `BlockManager` with respect to support for replicated off-heap storage. First, the locally-stored off-heap byte buffer is disposed of when it is replicated. It should not be. Second, the replica byte buffers are stored as heap byte buffers instead of direct byte buffers even when the storage level memory mode is off-heap. This PR addresses both of these problems. ## How was this patch tested? `BlockManagerReplicationSuite` was enhanced to fill in the coverage gaps. It now fails if either of the bugs in this PR exist. Author: Michael Allman <michael@videoamp.com> Closes #16499 from mallman/spark-17204-replicated_off_heap_storage.
Showing
- core/src/main/scala/org/apache/spark/storage/BlockManager.scala 20 additions, 3 deletions...rc/main/scala/org/apache/spark/storage/BlockManager.scala
- core/src/main/scala/org/apache/spark/storage/StorageUtils.scala 45 additions, 7 deletions...rc/main/scala/org/apache/spark/storage/StorageUtils.scala
- core/src/main/scala/org/apache/spark/util/ByteBufferInputStream.scala 2 additions, 6 deletions...n/scala/org/apache/spark/util/ByteBufferInputStream.scala
- core/src/main/scala/org/apache/spark/util/io/ChunkedByteBuffer.scala 22 additions, 5 deletions...in/scala/org/apache/spark/util/io/ChunkedByteBuffer.scala
- core/src/test/scala/org/apache/spark/storage/BlockManagerReplicationSuite.scala 16 additions, 4 deletions...g/apache/spark/storage/BlockManagerReplicationSuite.scala
Loading
Please register or sign in to comment