diff options
| -rw-r--r-- | core/src/test/scala/org/apache/spark/JavaAPISuite.java | 4 | ||||
| -rw-r--r-- | streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java | 8 |
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); |