Skip to content

Commit 6c54e06

Browse files
committed
Fix scalastyle
1 parent d8462d8 commit 6c54e06

File tree

2 files changed

+2
-4
lines changed

2 files changed

+2
-4
lines changed

core/src/main/scala/org/apache/spark/util/collection/ChainedBuffer.scala

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -142,5 +142,3 @@ private[spark] class ChainedBufferOutputStream(chainedBuffer: ChainedBuffer) ext
142142
pos += len
143143
}
144144
}
145-
146-
private[spark] class OffsetAndLength(var offs: Int, var len: Int)

core/src/main/scala/org/apache/spark/util/collection/ExternalSorter.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -747,8 +747,8 @@ private[spark] class ExternalSorter[K, V, C](
747747
val collection = if (aggregator.isDefined) map else buffer
748748
val it = collection.destructiveSortedWritablePartitionedIterator(comparator)
749749
while (it.hasNext) {
750-
val writer = blockManager.getDiskWriter(
751-
blockId, outputFile, serInstance, fileBufferSize, context.taskMetrics.shuffleWriteMetrics.get)
750+
val writer = blockManager.getDiskWriter(blockId, outputFile, serInstance, fileBufferSize,
751+
context.taskMetrics.shuffleWriteMetrics.get)
752752
val partitionId = it.nextPartition()
753753
while (it.hasNext && it.nextPartition() == partitionId) {
754754
it.writeNext(writer)

0 commit comments

Comments
 (0)