fix scala style bug

markhamstra · May 14, 2014 · 689495d · 689495d
1 parent 1d35c3c
commit 689495d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/core/src/main/scala/org/apache/spark/Partitioner.scala b/core/src/main/scala/org/apache/spark/Partitioner.scala
@@ -204,8 +204,9 @@ class BoundaryPartitioner[K : Ordering : ClassTag, V](
     * 3 partitions, 500 keys / partition and if rdd has 700 keys, 1 partition will be entirely
     * empty.
      */
-    if(counts(currPartition) >= keysPerPartition)
+    if(counts(currPartition) >= keysPerPartition) {
       currPartition = (currPartition + 1) % numPartitions
+    }
     partition
   }