diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-03-12 22:19:00 -0700 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-03-12 22:19:00 -0700 |
| commit | 00c4d238ddb368a9ef4c6251e232bd5808ba80f4 (patch) | |
| tree | db70b87d2b3f82cc357fd40fe4eaf8a0c19dae13 | |
| parent | cbf8f0d4dda41ffd45855eab8401fda9b64168cd (diff) | |
| parent | 769d399674f47caf840739ebfc9e7a5b5cb9aef6 (diff) | |
| download | spark-00c4d238ddb368a9ef4c6251e232bd5808ba80f4.tar.gz spark-00c4d238ddb368a9ef4c6251e232bd5808ba80f4.tar.bz2 spark-00c4d238ddb368a9ef4c6251e232bd5808ba80f4.zip | |
Merge pull request #518 from woggling/long-bm-sizes
Send block sizes as longs in BlockManager updates
| -rw-r--r-- | core/src/main/scala/spark/storage/BlockManagerMessages.scala | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/core/src/main/scala/spark/storage/BlockManagerMessages.scala b/core/src/main/scala/spark/storage/BlockManagerMessages.scala index 1494f90103..cff48d9909 100644 --- a/core/src/main/scala/spark/storage/BlockManagerMessages.scala +++ b/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() } } |