ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

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

Browse source 
Send block sizes as longs in BlockManager updates
This commit is contained in:
Matei Zaharia 2013-03-12 22:19:00 -07:00
parent cbf8f0d4dd 769d399674
commit 00c4d238dd
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
core/src/main/scala/spark/storage/BlockManagerMessages.scala
View file

@ -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()
}
}