No need call toInt

caneGuy · caneGuy · commit ab384d4e94ed · 2017-08-24T22:08:14.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
@@ -60,7 +60,7 @@ private[spark] class ChunkedByteBuffer(var chunks: Array[ByteBuffer]) {
     for (bytes <- getChunks()) {
       val capacity = bytes.limit()
       while (bytes.position() < capacity && bytes.remaining() > 0) {
-        val ioSize = Math.min(bytes.remaining(), NIO_BUFFER_LIMIT.toInt)
+        val ioSize = Math.min(bytes.remaining(), NIO_BUFFER_LIMIT)
         bytes.limit(bytes.position + ioSize)
         channel.write(bytes)
       }

Original file line number	Diff line number	Diff line change
`@@ -60,7 +60,7 @@ private[spark] class ChunkedByteBuffer(var chunks: Array[ByteBuffer]) {`
`60`	`60`	`for (bytes <- getChunks()) {`
`61`	`61`	`val capacity = bytes.limit()`
`62`	`62`	`while (bytes.position() < capacity && bytes.remaining() > 0) {`
`63`		`- val ioSize = Math.min(bytes.remaining(), NIO_BUFFER_LIMIT.toInt)`
	`63`	`+ val ioSize = Math.min(bytes.remaining(), NIO_BUFFER_LIMIT)`
`64`	`64`	`bytes.limit(bytes.position + ioSize)`
`65`	`65`	`channel.write(bytes)`
`66`	`66`	`}`