Skip to content

Commit

Permalink
Wrap long line
Browse files Browse the repository at this point in the history
  • Loading branch information
tedyu committed Sep 10, 2015
1 parent 63dfe11 commit 04aa45e
Showing 1 changed file with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -292,10 +292,11 @@ private[spark] class ExternalSorter[K, V, C](
while (it.hasNext) {
val partitionId = it.nextPartition()
if (partitionId < 0) {
throw new IllegalArgumentException("Encountered negative partition Id: " + partitionId)
throw new IllegalArgumentException("Encountered negative partition Id: " + partitionId)
}
if (partitionId >= numPartitions) {
throw new IllegalArgumentException("Encountered partition Id: " + partitionId + " which is >= " + numPartitions)
throw new IllegalArgumentException("Encountered partition Id: " + partitionId +
" which is >= " + numPartitions)
}
it.writeNext(writer)
elementsPerPartition(partitionId) += 1
Expand Down

0 comments on commit 04aa45e

Please sign in to comment.