Need to convert to int to fix compile error

caneGuy · caneGuy · commit 14ca824794ff · 2017-08-25T10:03:44.000+08:00
diff --git a/core/src/main/scala/org/apache/spark/util/io/ChunkedByteBuffer.scala b/core/src/main/scala/org/apache/spark/util/io/ChunkedByteBuffer.scala
@@ -65,7 +65,7 @@ private[spark] class ChunkedByteBuffer(var chunks: Array[ByteBuffer]) {
     for (bytes <- getChunks()) {
       while (bytes.remaining() > 0) {
         val ioSize = Math.min(bytes.remaining(), bufferWriteChunkSize)
-        bytes.limit(bytes.position + ioSize)
+        bytes.limit(bytes.position + ioSize.toInt)
         channel.write(bytes)
       }
     }

Original file line number	Diff line number	Diff line change
`@@ -65,7 +65,7 @@ private[spark] class ChunkedByteBuffer(var chunks: Array[ByteBuffer]) {`
`65`	`65`	`for (bytes <- getChunks()) {`
`66`	`66`	`while (bytes.remaining() > 0) {`
`67`	`67`	`val ioSize = Math.min(bytes.remaining(), bufferWriteChunkSize)`
`68`		`- bytes.limit(bytes.position + ioSize)`
	`68`	`+ bytes.limit(bytes.position + ioSize.toInt)`
`69`	`69`	`channel.write(bytes)`
`70`	`70`	`}`
`71`	`71`	`}`