Skip to content

Commit 689495d

Browse files
committed
fix scala style bug
1 parent 1d35c3c commit 689495d

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

core/src/main/scala/org/apache/spark/Partitioner.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -204,8 +204,9 @@ class BoundaryPartitioner[K : Ordering : ClassTag, V](
204204
* 3 partitions, 500 keys / partition and if rdd has 700 keys, 1 partition will be entirely
205205
* empty.
206206
*/
207-
if(counts(currPartition) >= keysPerPartition)
207+
if(counts(currPartition) >= keysPerPartition) {
208208
currPartition = (currPartition + 1) % numPartitions
209+
}
209210
partition
210211
}
211212

0 commit comments

Comments
 (0)