Skip to content

Commit 6aae02a

Browse files
ottercVictsm
andauthored
Update core/src/main/scala/org/apache/spark/shuffle/ShuffleBlockPusher.scala
Co-authored-by: Min Shen <[email protected]>
1 parent 762ac1e commit 6aae02a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

core/src/main/scala/org/apache/spark/shuffle/ShuffleBlockPusher.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -246,8 +246,8 @@ private[spark] class ShuffleBlockPusher(conf: SparkConf) extends Logging {
246246
Array(reqBuffer)
247247
} else {
248248
val inMemoryBuffer = reqBuffer.nioByteBuffer()
249-
val blockOffsets = new Array[Long](blockSizes.size)
250-
var offset = 0L
249+
val blockOffsets = new Array[Int](blockSizes.size)
250+
var offset = 0
251251
for (index <- blockSizes.indices) {
252252
blockOffsets(index) = offset
253253
offset += blockSizes(index)

0 commit comments

Comments
 (0)