Spacing fix

2 files changed, 6 insertions, 6 deletions

diff --git a/core/src/test/scala/org/apache/spark/JavaAPISuite.java b/core/src/test/scala/org/apache/spark/JavaAPISuite.java
index f38c607d65..352036f182 100644
--- a/core/src/test/scala/org/apache/spark/JavaAPISuite.java
+++ b/core/src/test/scala/org/apache/spark/JavaAPISuite.java
@@ -475,7 +475,7 @@ public class JavaAPISuite implements Serializable {
   @Test
   public void repartition() {
     // Shrinking number of partitions
-    JavaRDD<Integer> in1 = sc.parallelize(Arrays.asList(1,2,3,4,5,6,7,8), 2);
+    JavaRDD<Integer> in1 = sc.parallelize(Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8), 2);
     JavaRDD<Integer> repartitioned1 = in1.repartition(4);
     List<List<Integer>> result1 = repartitioned1.glom().collect();
     Assert.assertEquals(4, result1.size());
@@ -484,7 +484,7 @@ public class JavaAPISuite implements Serializable {
     }
 
     // Growing number of partitions
-    JavaRDD<Integer> in2 = sc.parallelize(Arrays.asList(1,2,3,4,5,6,7,8), 4);
+    JavaRDD<Integer> in2 = sc.parallelize(Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8), 4);
     JavaRDD<Integer> repartitioned2 = in2.repartition(2);
     List<List<Integer>> result2 = repartitioned2.glom().collect();
     Assert.assertEquals(2, result2.size());
diff --git a/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java b/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java
index 391d7ba21d..9da8adda83 100644
--- a/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java
+++ b/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java
@@ -186,8 +186,8 @@ public class JavaAPISuite implements Serializable {
   @Test
   public void testRepartitionMorePartitions() {
     List<List<Integer>> inputData = Arrays.asList(
-      Arrays.asList(1,2,3,4,5,6,7,8,9,10),
-      Arrays.asList(1,2,3,4,5,6,7,8,9,10));
+      Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10),
+      Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10));
     JavaDStream stream = JavaTestUtils.attachTestInputStream(ssc, inputData, 2);
     JavaDStream repartitioned = stream.repartition(4);
     JavaTestUtils.attachTestOutputStream(repartitioned);
@@ -203,8 +203,8 @@ public class JavaAPISuite implements Serializable {
   @Test
   public void testRepartitionFewerPartitions() {
     List<List<Integer>> inputData = Arrays.asList(
-      Arrays.asList(1,2,3,4,5,6,7,8,9,10),
-      Arrays.asList(1,2,3,4,5,6,7,8,9,10));
+      Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10),
+      Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10));
     JavaDStream stream = JavaTestUtils.attachTestInputStream(ssc, inputData, 4);
     JavaDStream repartitioned = stream.repartition(2);
     JavaTestUtils.attachTestOutputStream(repartitioned);