Skip to content
Snippets Groups Projects
Commit a6d38532 authored by Daoyuan Wang's avatar Daoyuan Wang Committed by Kousuke Saruta
Browse files

[SPARK-12222][CORE] Deserialize RoaringBitmap using Kryo serializer throw...

[SPARK-12222][CORE] Deserialize RoaringBitmap using Kryo serializer throw Buffer underflow exception

Since we only need to implement `def skipBytes(n: Int)`,
code in #10213 could be simplified.
davies scwf

Author: Daoyuan Wang <daoyuan.wang@intel.com>

Closes #10253 from adrian-wang/kryo.
parent 01ba95d8
No related branches found
No related tags found
No related merge requests found
......@@ -401,12 +401,7 @@ private[serializer] class KryoInputDataInputBridge(input: KryoInput) extends Dat
override def readInt(): Int = input.readInt()
override def readUnsignedShort(): Int = input.readShortUnsigned()
override def skipBytes(n: Int): Int = {
var remaining: Long = n
while (remaining > 0) {
val skip = Math.min(Integer.MAX_VALUE, remaining).asInstanceOf[Int]
input.skip(skip)
remaining -= skip
}
input.skip(n)
n
}
override def readFully(b: Array[Byte]): Unit = input.read(b)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment