Skip to content

Commit ee91bb7

Browse files
committed
Modified BufferMessage.scala to keep the spark code style
1 parent 9dfd0d8 commit ee91bb7

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

core/src/main/scala/org/apache/spark/network/BufferMessage.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,8 @@ class BufferMessage(id_ : Int, val buffers: ArrayBuffer[ByteBuffer], var ackId:
6666
}
6767
buffer.position(buffer.position + newBuffer.remaining)
6868
val newChunk = new MessageChunk(new MessageChunkHeader(
69-
typ, id, size, newBuffer.remaining, ackId, hasError, security, senderAddress), newBuffer)
69+
typ, id, size, newBuffer.remaining, ackId,
70+
hasError, security, senderAddress), newBuffer)
7071
gotChunkForSendingOnce = true
7172
return Some(newChunk)
7273
}

0 commit comments

Comments
 (0)