Skip to content
Browse files

Merge pull request #518 from woggling/long-bm-sizes

Send block sizes as longs in BlockManager updates
  • Loading branch information...
2 parents cbf8f0d + 769d399 commit 00c4d238ddb368a9ef4c6251e232bd5808ba80f4 @mateiz mateiz committed Mar 12, 2013
Showing with 4 additions and 4 deletions.
  1. +4 −4 core/src/main/scala/spark/storage/BlockManagerMessages.scala
View
8 core/src/main/scala/spark/storage/BlockManagerMessages.scala
@@ -49,16 +49,16 @@ class UpdateBlockInfo(
blockManagerId.writeExternal(out)
out.writeUTF(blockId)
storageLevel.writeExternal(out)
- out.writeInt(memSize.toInt)
- out.writeInt(diskSize.toInt)
+ out.writeLong(memSize)
+ out.writeLong(diskSize)
}
override def readExternal(in: ObjectInput) {
blockManagerId = BlockManagerId(in)
blockId = in.readUTF()
storageLevel = StorageLevel(in)
- memSize = in.readInt()
- diskSize = in.readInt()
+ memSize = in.readLong()
+ diskSize = in.readLong()
}
}

0 comments on commit 00c4d23

Please sign in to comment.
Something went wrong with that request. Please try again.