From 04aa45e56aa79c402fdb4d51e3972f850724b05d Mon Sep 17 00:00:00 2001 From: tedyu Date: Thu, 10 Sep 2015 12:15:02 -0700 Subject: [PATCH] Wrap long line --- .../org/apache/spark/util/collection/ExternalSorter.scala | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/core/src/main/scala/org/apache/spark/util/collection/ExternalSorter.scala b/core/src/main/scala/org/apache/spark/util/collection/ExternalSorter.scala index 5e9439f2f08e3..feddc6190381d 100644 --- a/core/src/main/scala/org/apache/spark/util/collection/ExternalSorter.scala +++ b/core/src/main/scala/org/apache/spark/util/collection/ExternalSorter.scala @@ -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